Lines Matching refs:receiver
59 mut receiver: FrameDataReceiver, in receive_frame_data_loop()
65 data = receiver.recv() => { in receive_frame_data_loop()
113 mut receiver: PacketDataReceiver, in receive_packet_data_loop()
119 data = receiver.recv() => { in receive_packet_data_loop()
164 mut receiver: TransmitterEventReceiver, in receive_event_loop()
170 if let Some(val) = receiver.recv().await { in receive_event_loop()
228 if let Some(receiver) = self.data_receiver.frame_receiver { in run()
231 receiver, in run()
237 if let Some(receiver) = self.data_receiver.packet_receiver { in run()
240 receiver, in run()
344 let (frame_sender, packet_sender, receiver) = match info.pub_data_type { in event_loop()
385 .publish(identifier.clone(), receiver, stream_handler) in event_loop()
433 let (sender, receiver) = match info.sub_data_type { in event_loop()
473 Ok(receiver) in event_loop()
659 receiver: DataReceiver, in publish()
669 let transmitter = Transmitter::new(receiver, event_consumer, handler); in publish()