Searched defs:StreamHubEventSender (Results 1 – 14 of 14) sorted by relevance
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 19 event_producer: StreamHubEventSender, // event_producer: ChannelEventProducer in handle_connection()
63 pub async fn run(event_producer: StreamHubEventSender, port: usize) -> Result<()> { in run()
|
| H A D | httpflv.rs | 43 event_producer: StreamHubEventSender, in new()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 15 pub fn new(address: String, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 18 event_producer: StreamHubEventSender, in new()
|
| H A D | flv_data_receiver.rs | 37 event_producer: StreamHubEventSender, in new()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 21 producer: StreamHubEventSender, in new()
|
| H A D | pull_client.rs | 20 producer: StreamHubEventSender, in new()
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 88 pub async fn run(producer: StreamHubEventSender, port: usize) { in run()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 302 sender: StreamHubEventSender, in unpublish_whip()
415 sender: StreamHubEventSender, in unsubscribe_whep()
|
| /xiu/library/streamhub/src/ |
| H A D | define.rs | 155 pub type StreamHubEventSender = mpsc::UnboundedSender<StreamHubEvent>; typedef
|
| H A D | lib.rs | 320 pub fn get_hub_event_sender(&mut self) -> StreamHubEventSender { in get_hub_event_sender()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 70 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
|
| H A D | common.rs | 57 event_producer: StreamHubEventSender, in new()
|
| H A D | client_session.rs | 100 event_producer: StreamHubEventSender, in new()
|