| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 5 define::{BroadcastEvent, BroadcastEventReceiver, StreamHubEventSender},
15 event_producer: StreamHubEventSender,
19 pub fn new(receiver: BroadcastEventReceiver, event_producer: StreamHubEventSender) -> Self { in new()
|
| H A D | rtsp2rtmp.rs | 26 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
35 event_producer: StreamHubEventSender,
57 pub fn new(stream_path: String, event_producer: StreamHubEventSender) -> Self { in new()
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 4 define::{BroadcastEvent, BroadcastEventReceiver, StreamHubEventSender},
11 event_producer: StreamHubEventSender,
18 event_producer: StreamHubEventSender, in new() argument
|
| H A D | flv_data_receiver.rs | 12 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
27 event_producer: StreamHubEventSender,
37 event_producer: StreamHubEventSender, in new() argument
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp.rs | 1 use streamhub::define::StreamHubEventSender;
10 event_producer: StreamHubEventSender,
14 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 1 use streamhub::define::StreamHubEventSender;
10 event_producer: StreamHubEventSender,
15 pub fn new(address: String, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new() argument
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 6 streamhub::define::{BroadcastEvent, BroadcastEventReceiver, StreamHubEventSender},
13 channel_event_producer: StreamHubEventSender,
20 producer: StreamHubEventSender, in new() argument
|
| H A D | push_client.rs | 5 define::{StreamHubEventSender, BroadcastEvent, BroadcastEventReceiver},
14 channel_event_producer: StreamHubEventSender,
21 producer: StreamHubEventSender, in new() argument
|
| /xiu/protocol/webrtc/src/ |
| H A D | webrtc.rs | 1 use streamhub::define::StreamHubEventSender;
16 event_producer: StreamHubEventSender,
21 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 10 streamhub::define::StreamHubEventSender,
19 event_producer: StreamHubEventSender, // event_producer: ChannelEventProducer in handle_connection() argument
63 pub async fn run(event_producer: StreamHubEventSender, port: usize) -> Result<()> { in run() argument
|
| H A D | httpflv.rs | 14 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
31 event_producer: StreamHubEventSender,
43 event_producer: StreamHubEventSender, in new() argument
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 9 streamhub::{define, define::StreamHubEventSender, utils::Uuid},
24 channel_event_producer: StreamHubEventSender,
88 pub async fn run(producer: StreamHubEventSender, port: usize) { in run() argument
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 5 StreamHubEventSender, SubscribeType, SubscriberInfo, TStreamHandler,
43 event_sender: StreamHubEventSender,
52 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new()
302 sender: StreamHubEventSender, in unpublish_whip() argument
415 sender: StreamHubEventSender, in unsubscribe_whep() argument
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 26 PublishType, PublisherInfo, StreamHubEvent, StreamHubEventSender, SubscribeType,
44 event_producer: StreamHubEventSender,
57 event_producer: StreamHubEventSender, in new() argument
|
| H A D | client_session.rs | 32 streamhub::define::StreamHubEventSender,
100 event_producer: StreamHubEventSender, in new() argument
|
| H A D | server_session.rs | 33 define::StreamHubEventSender,
70 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new() argument
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 17 StreamHubEvent, StreamHubEventReceiver, StreamHubEventSender, StreamStatisticSizeSender,
267 hub_event_sender: StreamHubEventSender,
320 pub fn get_hub_event_sender(&mut self) -> StreamHubEventSender { in get_hub_event_sender() argument
|
| H A D | define.rs | 155 pub type StreamHubEventSender = mpsc::UnboundedSender<StreamHubEvent>; typedef
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 52 StreamHubEvent, StreamHubEventSender, SubscribeType, SubscriberInfo, TStreamHandler,
72 event_producer: StreamHubEventSender,
105 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new()
|