Searched refs:stream_hub (Results 1 – 3 of 3) sorted by relevance
46 let mut stream_hub = StreamsHub::new(notifier); in run() localVariable48 self.start_httpflv(&mut stream_hub).await?; in run()49 self.start_hls(&mut stream_hub).await?; in run()50 self.start_rtmp(&mut stream_hub).await?; in run()51 self.start_rtsp(&mut stream_hub).await?; in run()52 self.start_webrtc(&mut stream_hub).await?; in run()54 self.start_rtmp_remuxer(&mut stream_hub).await?; in run()57 stream_hub.run().await; in run()64 let producer = stream_hub.get_hub_event_sender(); in start_http_api_server()185 stream_hub.set_rtmp_remuxer_enabled(true); in start_rtmp_remuxer()[all …]
22 let mut stream_hub = StreamsHub::new(None);23 let sender = stream_hub.get_hub_event_sender();35 tokio::spawn(async move { stream_hub.run().await });59 let mut stream_hub = StreamsHub::new(None);60 let sender = stream_hub.get_hub_event_sender();67 stream_hub.get_client_event_consumer(),75 stream_hub.set_rtmp_push_enabled(true);82 stream_hub.get_client_event_consumer(),91 stream_hub.set_rtmp_pull_enabled(true);104 tokio::spawn(async move { stream_hub.run().await });
53 let mut stream_hub = StreamsHub::new(None); in main() localVariable54 let producer = stream_hub.get_hub_event_sender(); in main()55 tokio::spawn(async move { stream_hub.run().await }); in main()