| /xiu/application/xiu/src/ |
| H A D | service.rs | 30 pub async fn run(&mut self) -> Result<()> { in run() method
57 stream_hub.run().await; in run()
73 api::run(producer, http_api_port).await; in start_http_api_server()
113 if let Err(err) = push_client.run().await { in start_rtmp()
137 if let Err(err) = pull_client.run().await { in start_rtmp()
151 if let Err(err) = rtmp_server.run().await { in start_rtmp()
188 if let Err(err) = remuxer.run().await { in start_rtmp_remuxer()
210 if let Err(err) = rtsp_server.run().await { in start_rtsp()
234 if let Err(err) = webrtc_server.run().await { in start_webrtc()
280 if let Err(err) = hls_remuxer.run().await { in start_hls()
[all …]
|
| H A D | api.rs | 88 pub async fn run(producer: StreamHubEventSender, port: usize) { in run() function
|
| H A D | main.rs | 187 service.run().await?; in main()
|
| /xiu/.github/workflows/ |
| H A D | rust.yml | 20 run: cargo build --verbose
22 run: cargo test --verbose
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 25 pub async fn run(&mut self) -> Result<(), RtmpRemuxerError> { in run() method
37 if let Err(err) = session.run().await { in run()
|
| H A D | rtsp2rtmp.rs | 87 pub async fn run(&mut self) -> Result<(), RtmpRemuxerError> { in run() method
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 28 pub async fn run(&mut self) -> Result<(), HlsError> { in run() method
47 if let Err(err) = rtmp_subscriber.run().await { in run()
|
| H A D | server.rs | 72 pub async fn run(port: usize) -> Result<()> { in run() function
|
| H A D | flv_data_receiver.rs | 54 pub async fn run(&mut self) -> Result<(), HlsError> { in run() method
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp.rs | 21 pub async fn run(&mut self) -> Result<(), Error> { in run() method
30 if let Err(err) = session.run().await { in run()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 23 pub async fn run(&mut self) -> Result<(), Error> { in run() method
38 if let Err(err) = session.run().await { in run()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 30 pub async fn run(&mut self) -> Result<(), ClientError> { in run() method
60 if let Err(err) = client_session.run().await { in run()
|
| H A D | push_client.rs | 31 pub async fn run(&mut self) -> Result<(), ClientError> { in run() method
63 if let Err(err) = client_session.run().await { in run()
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 30 if let Err(err) = rtmp_server.run().await {
35 tokio::spawn(async move { stream_hub.run().await });
71 if let Err(err) = push_client.run().await {
87 if let Err(err) = pull_client.run().await {
99 if let Err(err) = rtmp_server.run().await {
104 tokio::spawn(async move { stream_hub.run().await });
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 55 tokio::spawn(async move { stream_hub.run().await }); in main()
73 if let Err(err) = pull_client_session.run().await { in main()
99 if let Err(err) = push_client_session.run().await { in main()
|
| /xiu/protocol/webrtc/src/ |
| H A D | webrtc.rs | 29 pub async fn run(&mut self) -> Result<(), Error> { in run() method
43 if let Err(err) = session_unlock.run(uuid_2_sessions.clone()).await { in run()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 44 if let Err(err) = flv_hanlder.run().await { in handle_connection()
63 pub async fn run(event_producer: StreamHubEventSender, port: usize) -> Result<()> { in run() function
|
| H A D | httpflv.rs | 64 pub async fn run(&mut self) -> Result<(), HttpFLvError> { in run() method
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 225 pub async fn run(self) -> Result<(), ChannelError> { in run() method
300 pub async fn run(&mut self) { in run() method
673 if let Err(err) = transmitter.run().await { in publish()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 75 pub async fn run( in run() method
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 145 pub async fn run(&mut self) -> Result<(), SessionError> { in run() method
|
| H A D | server_session.rs | 103 pub async fn run(&mut self) -> Result<(), SessionError> { in run() method
|
| /xiu/ |
| H A D | README.md | 62 ## Install and run
|
| /xiu/application/xiu/ |
| H A D | README.md | 57 ## Install and run
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 128 pub async fn run(&mut self) -> Result<(), SessionError> { in run() method
|