Searched refs:sender (Results 1 – 10 of 10) sorted by relevance
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 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()
438 sender: sender_chan, in event_loop()
450 sender: sender_chan, 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()
[all …]
|
| H A D | define.rs | 178 sender: DataSender, in send_prior_data()
182 async fn send_information(&self, sender: InformationSender); in send_information()
194 Frame { sender: FrameDataSender },
195 Packet { sender: PacketDataSender },
246 sender: InformationSender,
253 sender: DataSender,
262 sender: AvStatisticSender,
265 sender: InformationSender,
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 23 let sender = stream_hub.get_hub_event_sender();
28 let mut rtmp_server = RtmpServer::new(address, sender, 1);
60 let sender = stream_hub.get_hub_event_sender();
68 sender.clone(),
83 sender.clone(),
97 let mut rtmp_server = RtmpServer::new(address, sender.clone(), 1);
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 232 let (sender, mut receiver) = mpsc::unbounded_channel(); in handle_describe()
238 sender, in handle_describe()
295 let sender = event_result_receiver.await??.0.unwrap(); in handle_announce() localVariable
298 let sender_out = sender.clone(); in handle_announce()
728 let sender = match data_sender { in send_prior_data() localVariable
729 DataSender::Frame { sender } => sender, in send_prior_data()
730 DataSender::Packet { sender: _ } => { in send_prior_data()
758 if let Err(err) = sender.send(frame_data) { in send_prior_data()
797 if let Err(err) = sender.send(FrameData::MediaInfo { in send_prior_data()
818 async fn send_information(&self, sender: InformationSender) { in send_information()
[all …]
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 489 let sender = match data_sender { in send_prior_data() localVariable
490 DataSender::Frame { sender } => sender, in send_prior_data()
491 DataSender::Packet { sender: _ } => { in send_prior_data()
499 sender.send(meta_body_data).map_err(|_| ChannelError { in send_prior_data()
504 sender.send(audio_seq_data).map_err(|_| ChannelError { in send_prior_data()
509 sender.send(video_seq_data).map_err(|_| ChannelError { in send_prior_data()
521 sender.send(channel_data).map_err(|_| ChannelError { in send_prior_data()
|
| /xiu/library/streamhub/src/statistics/ |
| H A D | avstatistics.rs | 32 pub sender: Sender<bool>, field
44 sender: s, in new()
96 self.sender = s; in start()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 271 let sender = event_result_receiver.await??.1.unwrap(); in publish_whip() localVariable
273 let response = match handle_whip(offer, sender).await { in publish_whip()
302 sender: StreamHubEventSender, in unpublish_whip()
312 if sender.send(unpublish_event).is_err() { in unpublish_whip()
415 sender: StreamHubEventSender, in unsubscribe_whep()
425 if sender.send(unsubscribe_event).is_err() { in unsubscribe_whep()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whip.rs | 28 sender: PacketDataSender, in handle_whip()
110 let sender_clone = sender.clone(); in handle_whip()
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 177 if let Some(sender) = &self.close_sender { in stop()
178 if let Err(err) = sender.send(true) { in stop()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | mod.rs | 39 self.av_statistics.sender.send(true); in drop()
|