Searched refs:data_consumer (Results 1 – 3 of 3) sorted by relevance
28 data_consumer: FrameDataReceiver, field41 let (_, data_consumer) = mpsc::unbounded_channel(); in new()47 data_consumer, in new()66 if let Some(data) = self.data_consumer.recv().await { in receive_flv_data()136 self.data_consumer = receiver; in subscribe_from_rtmp_channels()
32 data_consumer: FrameDataReceiver, field48 let (_, data_consumer) = mpsc::unbounded_channel(); in new()55 data_consumer, in new()79 if let Some(data) = self.data_consumer.recv().await { in send_media_stream()201 self.data_consumer = receiver; in subscribe_from_rtmp_channels()
58 let (_, data_consumer) = mpsc::unbounded_channel(); in new()75 data_receiver: data_consumer, in new()