21     errors::{ChannelError, ChannelErrorValue},
79 …                            if let Err(audio_err) = v.send(data.clone()).map_err(|_| ChannelError {  in receive_frame_data_loop()
92 …                            if let Err(video_err) = v.send(data.clone()).map_err(|_| ChannelError {  in receive_frame_data_loop()
130 …                            if let Err(audio_err) = v.send(data.clone()).map_err(|_| ChannelError {  in receive_packet_data_loop()
143 …                            if let Err(video_err) = v.send(data.clone()).map_err(|_| ChannelError {  in receive_packet_data_loop()
225     pub async fn run(self) -> Result<(), ChannelError> {  in run()  argument
521     ) -> Result<(), ChannelError> {  in request()  argument
525             producer.send(event).map_err(|_| ChannelError {  in request()
536     ) -> Result<(), ChannelError> {  in api_statistic()  argument
544                 return Err(ChannelError {  in api_statistic()
552             return Err(ChannelError {  in api_statistic()
598     ) -> Result<(), ChannelError> {  in subscribe()  argument
605             producer.send(event).map_err(|_| ChannelError {  in subscribe()
622                 .map_err(|_| ChannelError {  in subscribe()
627         Err(ChannelError {  in subscribe()
636     ) -> Result<(), ChannelError> {  in unsubscribe()  argument
641                 producer.send(event).map_err(|_| ChannelError {  in unsubscribe()
646                 return Err(ChannelError {  in unsubscribe()
661     ) -> Result<(), ChannelError> {  in publish()  argument
663             return Err(ChannelError {  in publish()
691                 .map_err(|_| ChannelError {  in publish()
699     fn unpublish(&mut self, identifier: &StreamIdentifier) -> Result<(), ChannelError> {  in unpublish()  argument
703                 producer.send(event).map_err(|_| ChannelError {  in unpublish()
710                 return Err(ChannelError {  in unpublish()