Searched refs:StreamHubEvent (Results 1 – 9 of 9) sorted by relevance
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 12 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
118 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_rtmp_channels()
157 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_rtmp_channels()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 14 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
155 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_rtmp_channels()
184 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_rtmp_channels()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 17 StreamHubEvent, StreamHubEventReceiver, StreamHubEventSender, StreamStatisticSizeSender,
338 StreamHubEvent::Publish { in event_loop()
408 StreamHubEvent::UnPublish { in event_loop()
424 StreamHubEvent::Subscribe { in event_loop()
485 StreamHubEvent::UnSubscribe { identifier, info } => { in event_loop()
493 StreamHubEvent::ApiStatistic { in event_loop()
501 StreamHubEvent::ApiKickClient { id } => { in event_loop()
508 StreamHubEvent::Request { identifier, sender } => { in event_loop()
|
| H A D | define.rs | 155 pub type StreamHubEventSender = mpsc::UnboundedSender<StreamHubEvent>;
156 pub type StreamHubEventReceiver = mpsc::UnboundedReceiver<StreamHubEvent>;
212 pub enum StreamHubEvent { enum
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 39 let hub_event = define::StreamHubEvent::ApiStatistic { in get_stream_status()
77 let hub_event = define::StreamHubEvent::ApiKickClient { id }; in kick_off_client()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 26 PublishType, PublisherInfo, StreamHubEvent, StreamHubEventSender, SubscribeType,
315 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_channels()
345 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_channels()
369 let publish_event = StreamHubEvent::Publish { in publish_to_channels()
401 let unpublish_event = StreamHubEvent::UnPublish { in unpublish_to_channels()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 4 DataSender, InformationSender, NotifyInfo, PublishType, PublisherInfo, StreamHubEvent,
255 let publish_event = StreamHubEvent::Publish { in publish_whip()
304 let unpublish_event = StreamHubEvent::UnPublish { in unpublish_whip()
332 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_whep()
417 let unsubscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_whep()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 26 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
131 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_rtsp()
161 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_rtsp()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 52 StreamHubEvent, StreamHubEventSender, SubscribeType, SubscriberInfo, TStreamHandler,
234 let request_event = StreamHubEvent::Request { in handle_describe()
280 let publish_event = StreamHubEvent::Publish { in handle_announce()
466 let publish_event = StreamHubEvent::Subscribe { in handle_play()
533 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_stream_hub()
565 let unpublish_event = StreamHubEvent::UnPublish { in handle_teardown()
|