| /xiu/library/streamhub/src/ |
| H A D | stream.rs | 5 pub enum StreamIdentifier { enum
20 impl fmt::Display for StreamIdentifier { implementation
23 StreamIdentifier::Rtmp { in fmt()
29 StreamIdentifier::Rtsp { in fmt()
34 StreamIdentifier::WebRTC { in fmt()
43 StreamIdentifier::Unkonwn => { in fmt()
|
| H A D | define.rs | 6 crate::stream::StreamIdentifier,
214 identifier: StreamIdentifier,
220 identifier: StreamIdentifier,
224 identifier: StreamIdentifier,
232 identifier: StreamIdentifier,
245 identifier: StreamIdentifier,
278 Publish { identifier: StreamIdentifier },
279 UnPublish { identifier: StreamIdentifier },
281 Subscribe { identifier: StreamIdentifier },
289 identifier: StreamIdentifier,
[all …]
|
| H A D | lib.rs | 24 stream::StreamIdentifier,
261 streams: HashMap<StreamIdentifier, TransmitterEventSender>,
519 identifier: &StreamIdentifier, in request() argument
595 identifer: &StreamIdentifier, in subscribe() argument
634 identifer: &StreamIdentifier, in unsubscribe() argument
658 identifier: StreamIdentifier, in publish() argument
699 fn unpublish(&mut self, identifier: &StreamIdentifier) -> Result<(), ChannelError> { in unpublish()
|
| /xiu/library/streamhub/src/statistics/ |
| H A D | mod.rs | 4 super::stream::StreamIdentifier,
32 identifier: StreamIdentifier,
38 pub fn new(identifier: StreamIdentifier) -> Self { in new()
|
| H A D | avstatistics.rs | 1 use crate::stream::StreamIdentifier;
36 pub fn new(identifier: StreamIdentifier) -> Self { in new()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 6 stream::StreamIdentifier,
33 if let StreamIdentifier::Rtsp { stream_path } = identifier { in run()
|
| H A D | rtsp2rtmp.rs | 29 stream::StreamIdentifier,
132 identifier: StreamIdentifier::Rtsp { in subscribe_rtsp()
162 identifier: StreamIdentifier::Rtsp { in unsubscribe_rtsp()
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 5 stream::StreamIdentifier,
33 if let StreamIdentifier::Rtmp { in run()
|
| H A D | flv_data_receiver.rs | 15 stream::StreamIdentifier,
111 let identifier = StreamIdentifier::Rtmp { in subscribe_from_rtmp_channels()
152 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 1 use streamhub::stream::StreamIdentifier;
36 StreamIdentifier::Rtmp { in run()
|
| H A D | push_client.rs | 6 stream::StreamIdentifier,
39 if let StreamIdentifier::Rtmp { in run()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 18 stream::StreamIdentifier,
150 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_rtmp_channels()
177 let identifier = StreamIdentifier::Rtmp { in subscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 31 stream::StreamIdentifier,
308 let identifier = StreamIdentifier::Rtmp { in subscribe_from_channels()
340 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_channels()
370 identifier: StreamIdentifier::Rtmp { in publish_to_channels()
402 identifier: StreamIdentifier::Rtmp { in unpublish_to_channels()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | mod.rs | 14 streamhub::stream::StreamIdentifier,
45 let identifier = StreamIdentifier::Rtmp { in new()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 9 stream::StreamIdentifier,
256 identifier: StreamIdentifier::WebRTC { in publish_whip()
305 identifier: StreamIdentifier::WebRTC { in unpublish_whip()
333 identifier: StreamIdentifier::WebRTC { in subscribe_whep()
418 identifier: StreamIdentifier::WebRTC { in unsubscribe_whep()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 56 stream::StreamIdentifier,
235 identifier: StreamIdentifier::Rtsp { in handle_describe()
281 identifier: StreamIdentifier::Rtsp { in handle_announce()
467 identifier: StreamIdentifier::Rtsp { in handle_play()
531 let identifier = StreamIdentifier::Rtsp { stream_path }; in unsubscribe_from_stream_hub()
566 identifier: StreamIdentifier::Rtsp { in handle_teardown()
|