Searched refs:stream_handler (Results 1 – 5 of 5) sorted by relevance
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 51 pub stream_handler: Arc<RtmpStreamHandler>, field
74 stream_handler: Arc::new(RtmpStreamHandler::new()), in new()
188 self.stream_handler in on_video_data()
215 self.stream_handler in on_audio_data()
241 self.stream_handler.save_metadata(data, *timestamp).await; in on_meta_data()
364 self.stream_handler in publish_to_channels()
375 stream_handler: self.stream_handler.clone(), in publish_to_channels()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 39 stream_handler: Arc<dyn TStreamHandler>, field
53 stream_handler: h, in new()
162 stream_handler: Arc<dyn TStreamHandler>, in receive_event_loop()
173 if let Err(err) = stream_handler in receive_event_loop()
209 stream_handler.get_statistic_data().await in receive_event_loop()
217 stream_handler.send_information(sender).await; in receive_event_loop()
247 self.stream_handler, in run()
342 stream_handler, in event_loop()
385 .publish(identifier.clone(), receiver, stream_handler) in event_loop()
|
| H A D | define.rs | 229 stream_handler: Arc<dyn TStreamHandler>,
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 44 stream_handler: Arc<WebRTCStreamHandler>, field
61 stream_handler: Arc::new(WebRTCStreamHandler::new()), in new()
262 stream_handler: self.stream_handler.clone(), in publish_whip()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 71 stream_handler: Arc<RtspStreamHandler>, field
124 stream_handler: Arc::new(RtspStreamHandler::new()), in new()
271 self.stream_handler.set_sdp(sdp).await; in handle_announce()
286 stream_handler: self.stream_handler.clone(), in handle_announce()
|