| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 339 identifier, in event_loop()
409 identifier, in event_loop()
416 identifier in event_loop()
425 identifier, in event_loop()
469 identifier, in event_loop()
519 identifier: &StreamIdentifier, in request()
573 identifier in api_kick_off_client()
578 identifier, in api_kick_off_client()
585 identifier in api_kick_off_client()
616 identifier: identifer.clone(), in subscribe()
[all …]
|
| H A D | define.rs | 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 },
282 UnSubscribe { identifier: StreamIdentifier },
289 identifier: StreamIdentifier,
[all …]
|
| /xiu/library/streamhub/src/statistics/ |
| H A D | mod.rs | 32 identifier: StreamIdentifier, field
38 pub fn new(identifier: StreamIdentifier) -> Self { in new()
40 identifier, in new()
|
| H A D | avstatistics.rs | 36 pub fn new(identifier: StreamIdentifier) -> Self { in new()
43 stream_statistics: Arc::new(Mutex::new(StreamStatistics::new(identifier))), in new()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 32 BroadcastEvent::Publish { identifier } => { in run()
33 if let StreamIdentifier::Rtsp { stream_path } = identifier { in run()
|
| H A D | rtsp2rtmp.rs | 132 identifier: StreamIdentifier::Rtsp { in subscribe_rtsp()
162 identifier: StreamIdentifier::Rtsp { in unsubscribe_rtsp()
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 32 BroadcastEvent::Publish { identifier } => { in run()
36 } = identifier in run()
|
| H A D | flv_data_receiver.rs | 111 let identifier = StreamIdentifier::Rtmp { in subscribe_from_rtmp_channels() localVariable
119 identifier, in subscribe_from_rtmp_channels()
152 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_rtmp_channels() localVariable
158 identifier, in unsubscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 38 BroadcastEvent::Publish { identifier } => { in run()
42 } = identifier in run()
|
| H A D | pull_client.rs | 35 identifier: in run()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 150 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_rtmp_channels() localVariable
156 identifier, in unsubscribe_from_rtmp_channels()
177 let identifier = StreamIdentifier::Rtmp { in subscribe_from_rtmp_channels() localVariable
185 identifier, in subscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 308 let identifier = StreamIdentifier::Rtmp { in subscribe_from_channels() localVariable
316 identifier, in subscribe_from_channels()
340 let identifier = StreamIdentifier::Rtmp { in unsubscribe_from_channels() localVariable
346 identifier, 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 | 45 let identifier = StreamIdentifier::Rtmp { in new() localVariable
57 av_statistics: AvStatistics::new(identifier), in new()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 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 | 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() localVariable
534 identifier, in unsubscribe_from_stream_hub()
566 identifier: StreamIdentifier::Rtsp { in handle_teardown()
|