Lines Matching refs:sender
172 TransmitterEvent::Subscribe { sender, info } => { in receive_event_loop()
174 .send_prior_data(sender.clone(), info.sub_type) in receive_event_loop()
180 match sender { in receive_event_loop()
182 sender: frame_sender, in receive_event_loop()
187 sender: packet_sender, in receive_event_loop()
207 TransmitterEvent::Api { sender } => { in receive_event_loop()
211 if let Err(err) = sender.send(avstatistic_data) { in receive_event_loop()
216 TransmitterEvent::Request { sender } => { in receive_event_loop()
217 stream_handler.send_information(sender).await; in receive_event_loop()
433 let (sender, receiver) = match info.sub_data_type { in event_loop()
438 sender: sender_chan, in event_loop()
450 sender: sender_chan, in event_loop()
460 let rv = match self.subscribe(&identifier, info_clone, sender).await { in event_loop()
508 StreamHubEvent::Request { identifier, sender } => { in event_loop()
509 if let Err(err) = self.request(&identifier, sender) { in event_loop()
520 sender: mpsc::UnboundedSender<Information>, in request()
523 let event = TransmitterEvent::Request { sender }; in request()
541 sender: data_sender.clone(), in api_statistic()
597 sender: DataSender, in subscribe()
601 sender, in subscribe()