Searched refs:stream_path (Results 1 – 4 of 4) sorted by relevance
| /xiu/library/streamhub/src/ |
| H A D | stream.rs | 13 stream_path: String,
30 stream_path: stream_name, in fmt()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 33 if let StreamIdentifier::Rtsp { stream_path } = identifier { in run()
35 Rtsp2RtmpRemuxerSession::new(stream_path, self.event_producer.clone()); in run()
|
| H A D | rtsp2rtmp.rs | 43 stream_path: String, field
57 pub fn new(stream_path: String, event_producer: StreamHubEventSender) -> Self { in new()
60 let eles: Vec<&str> = stream_path.splitn(2, '/').collect(); in new()
64 stream_path in new()
72 stream_path, in new()
133 stream_path: self.stream_path.clone(), in subscribe_rtsp()
163 stream_path: self.stream_path.clone(), in unsubscribe_rtsp()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 236 stream_path: rtsp_request.path.clone(), in handle_describe()
282 stream_path: rtsp_request.path.clone(), in handle_announce()
468 stream_path: rtsp_request.path.clone(), in handle_play()
530 pub fn unsubscribe_from_stream_hub(&mut self, stream_path: String) -> Result<(), SessionError> { in unsubscribe_from_stream_hub()
531 let identifier = StreamIdentifier::Rtsp { stream_path }; in unsubscribe_from_stream_hub()
564 let stream_path = &rtsp_request.path; in handle_teardown() localVariable
567 stream_path: stream_path.clone(), in handle_teardown()
575 log::error!("unpublish_to_channels error.stream_name: {}", stream_path); in handle_teardown()
583 stream_path in handle_teardown()
|