Searched refs:receiver (Results 1 – 10 of 10) sorted by relevance
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 14 receiver: BroadcastEventReceiver, field
19 pub fn new(receiver: BroadcastEventReceiver, event_producer: StreamHubEventSender) -> Self { in new()
21 receiver, in new()
29 let val = self.receiver.recv().await?; in run()
|
| H A D | rtsp2rtmp.rs | 145 let receiver = event_result_receiver.await??; in subscribe_rtsp() localVariable
146 self.data_receiver = receiver.frame_receiver.unwrap(); in subscribe_rtsp()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 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()
240 receiver, in run()
473 Ok(receiver) in event_loop()
[all …]
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 134 let receiver = event_result_receiver.await??.frame_receiver.unwrap(); in subscribe_from_rtmp_channels() localVariable
136 self.data_consumer = receiver; in subscribe_from_rtmp_channels()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 200 let receiver = event_result_receiver.await??.frame_receiver.unwrap(); in subscribe_from_rtmp_channels() localVariable
201 self.data_consumer = receiver; in subscribe_from_rtmp_channels()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whep.rs | 30 mut receiver: PacketDataReceiver, in handle_whep()
158 av_data = receiver.recv() =>{ in handle_whep()
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 164 let (send, receiver) = channel::<bool>(); in new()
166 gen_log_file_thread_run(handler, rotate_val, path_val, receiver); in new()
|
| /xiu/protocol/webrtc/src/clients/ |
| H A D | whep.js | 302 kind: transceivers[0].receiver.track.kind,
318 kind: transceiver.receiver.track.kind,
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 232 let (sender, mut receiver) = mpsc::unbounded_channel(); in handle_describe()
247 if let Some(Information::Sdp { data }) = receiver.recv().await { in handle_describe()
480 let mut receiver = event_result_receiver.await??.frame_receiver.unwrap(); in handle_play() localVariable
484 if let Some(frame_data) = receiver.recv().await { in handle_play()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 347 let receiver = event_result_receiver.await??.packet_receiver.unwrap(); in subscribe_whep() localVariable
351 let response = match handle_whep(offer, receiver, pc_state_sender).await { in subscribe_whep()
|