Searched refs:data_receiver (Results 1 – 4 of 4) sorted by relevance
37 let (data_sender, mut data_receiver) = mpsc::unbounded_channel(); in get_stream_status()53 if let Some(stream_statistics) = data_receiver.recv().await { in get_stream_status()
42 data_receiver: FrameDataReceiver, field75 data_receiver: data_consumer, in new()146 self.data_receiver = receiver.frame_receiver.unwrap(); in subscribe_rtsp()178 if let Some(data) = self.data_receiver.recv().await { in receive_rtsp_data()
41 data_receiver: FrameDataReceiver, field68 data_receiver: init_consumer, in new()81 if let Some(data) = self.data_receiver.recv().await { in send_channel_data()329 self.data_receiver = recv.frame_receiver.unwrap(); in subscribe_from_channels()
32 data_receiver: DataReceiver, field44 data_receiver: DataReceiver, in new()49 data_receiver, in new()228 if let Some(receiver) = self.data_receiver.frame_receiver { in run()237 if let Some(receiver) = self.data_receiver.packet_receiver { in run()