| /xiu/protocol/httpflv/ |
| H A D | README.md | 3 - Support remux RTMP stream to httpflv stream.
13 - Support stream status notify using HTTP.
|
| /xiu/protocol/webrtc/ |
| H A D | README.md | 3 - Support receiving RTC stream using Whip
4 - Support sending RTC stream using Whop
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 1 use streamhub::stream::StreamIdentifier;
47 let stream = TcpStream::connect(self.address.clone()).await?; in run() localVariable
50 stream, in run()
|
| H A D | push_client.rs | 6 stream::StreamIdentifier,
50 let stream = TcpStream::connect(self.address.clone()).await?; in run() localVariable
53 stream, in run()
|
| /xiu/protocol/hls/ |
| H A D | README.md | 3 Support remux RTMP stream to hls stream.
21 - Support stream status notify using HTTP.
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 93 stream: Framed<TcpStream, BytesCodec>, field
98 pub fn new(stream: TcpStream) -> Self { in new()
100 stream: Framed::new(stream, BytesCodec::new()), in new()
113 self.stream.send(bytes).await?; in write()
128 let message = self.stream.next().await; in read()
|
| /xiu/library/container/mpegts/src/ |
| H A D | pmt.rs | 83 for stream in &pmt.streams { in write()
85 let stream_type = if stream.codec_id == epsi_stream_type::PSI_STREAM_AUDIO_OPUS { in write()
88 stream.codec_id in write()
92 tmp_bytes_writer.write_u16::<BigEndian>(0xE000 | stream.pid)?; in write()
|
| H A D | ts.rs | 327 for stream in pmt.streams.iter_mut() { in find_stream()
328 if stream.pid == pid { in find_stream()
|
| /xiu/application/xiu/ |
| H A D | README.md | 41 - [x] Support publishing rtc stream using Whip.
42 - [x] Support subscribing rtc stream using Whep.
46 - [x] Support querying stream information.
47 - [x] Support notification of stream status.
175 # need record the live stream or not
214 - Use OBS to push a live rtmp stream
215 - Or use FFmpeg to push a rtmp stream:
246 - How to play WebRTC stream*(Whep)
281 …s to push rtmp live stream to service 1, then the stream can be pushed to service 2 automatically,…
314 …se the above methods to push live stream to service 1, when you play the stream from serivce 2, it…
[all …]
|
| /xiu/ |
| H A D | README.md | 46 - [x] Support publishing rtc stream using Whip.
47 - [x] Support subscribing rtc stream using Whep.
51 - [x] Support querying stream information.
52 - [x] Support notification of stream status.
180 # need record the live stream or not
219 - Use OBS to push a live rtmp stream
220 - Or use FFmpeg to push a rtmp stream:
243 Use ffplay to play the rtmp/rtsp/httpflv/hls live stream:
251 - How to play WebRTC stream*(Whep)
286 …s to push rtmp live stream to service 1, then the stream can be pushed to service 2 automatically,…
[all …]
|
| /xiu/protocol/rtsp/ |
| H A D | README.md | 3 - Support subscribe/publish RTSP stream
|
| /xiu/protocol/hls/src/ |
| H A D | server.rs | 64 let stream = FramedRead::new(file, BytesCodec::new()); in simple_file_send() localVariable
65 let body = Body::wrap_stream(stream); in simple_file_send()
|
| H A D | remuxer.rs | 5 stream::StreamIdentifier,
|
| H A D | flv_data_receiver.rs | 15 stream::StreamIdentifier,
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 62 // push the rtmp stream from local to 192.168.0.2:1935
77 //pull the rtmp stream from 192.168.0.3:1935 to local
154 - Support notify stream status.
158 - Fix error that cannot receive rtmp stream pushed from GStreamer.
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 6 stream::StreamIdentifier,
|
| /xiu/library/bytesio/ |
| H A D | Cargo.toml | 19 tokio-stream = { version = "0.1" }
|
| /xiu/library/streamhub/src/statistics/ |
| H A D | mod.rs | 4 super::stream::StreamIdentifier,
|
| H A D | avstatistics.rs | 1 use crate::stream::StreamIdentifier;
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 9 stream::StreamIdentifier,
52 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new()
53 let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 95 stream: TcpStream, in new()
103 let remote_addr = if let Ok(addr) = stream.peer_addr() { in new()
110 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|
| H A D | server_session.rs | 70 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
71 let remote_addr = if let Ok(addr) = stream.peer_addr() { in new()
78 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | mod.rs | 14 streamhub::stream::StreamIdentifier,
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 18 stream::StreamIdentifier,
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 56 stream::StreamIdentifier,
105 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new()
113 let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|