| /xiu/ |
| H A D | README_CN.md | 6 []…
7 [](https://crates.io/crates/xiu)
8 [](https://crates.io/crates/rtmp)
10 [](https://crates.io/crates/xrtsp)
13 [](https://crates.io/crates/xwebrtc)
16 []…
17 [](https://crates.io/crates/hls)
18 […
[all …]
|
| H A D | Cargo.lock | 8 source = "registry+https://github.com/rust-lang/crates.io-index"
17 source = "registry+https://github.com/rust-lang/crates.io-index"
23 source = "registry+https://github.com/rust-lang/crates.io-index"
32 source = "registry+https://github.com/rust-lang/crates.io-index"
42 source = "registry+https://github.com/rust-lang/crates.io-index"
1056 "futures-io",
1090 name = "futures-io"
1126 "futures-io",
1526 name = "io-lifetimes"
1548 "io-lifetimes",
[all …]
|
| H A D | README.md | 6 []…
7 [](https://crates.io/crates/xiu)
8 [](https://crates.io/crates/rtmp)
10 [](https://crates.io/crates/xrtsp)
13 [](https://crates.io/crates/xwebrtc)
16 []…
17 [](https://crates.io/crates/hls)
18 […
[all …]
|
| /xiu/application/xiu/ |
| H A D | README.md | 5 []…
6 [](https://crates.io/crates/xiu)
7 [](https://crates.io/crates/rtmp)
9 [](https://crates.io/crates/xrtsp)
12 [](https://crates.io/crates/xwebrtc)
15 []…
16 [](https://crates.io/crates/hls)
17 […
[all …]
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_errors.rs | 2 use std::io;
15 IO(#[cause] io::Error),
35 impl From<io::Error> for BytesReadError {
36 fn from(error: io::Error) -> Self { in from()
67 IO(io::Error),
76 impl From<io::Error> for BytesWriteError {
77 fn from(error: io::Error) -> Self { in from()
|
| H A D | bytesio_errors.rs | 3 use std::io;
13 IOError(io::Error),
30 impl From<io::Error> for BytesIOError {
31 fn from(error: io::Error) -> Self { in from()
|
| H A D | bytes_writer.rs | 10 std::{io::Write, sync::Arc, time::Duration},
156 pub io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
160 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
163 io, in new()
200 self.io in flush()
212 self.io in flush_timeout()
236 use std::io::Write;
|
| H A D | bytes_reader.rs | 8 std::{io::Cursor, sync::Arc},
153 pub io: Arc<Mutex<T1>>, field
160 pub fn new(io: Arc<Mutex<T1>>) -> Self { in new()
163 io, in new()
168 let data = self.io.lock().await.read().await?; in read()
|
| /xiu/protocol/httpflv/src/ |
| H A D | define.rs | 3 {bytes::BytesMut, std::io},
10 pub type HttpResponseDataProducer = UnboundedSender<io::Result<BytesMut>>;
11 pub type HttpResponseDataConsumer = UnboundedReceiver<io::Result<BytesMut>>;
|
| /xiu/library/logger/src/ |
| H A D | target.rs | 4 std::{fs::File, io},
19 impl io::Write for FileTarget {
20 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
29 fn flush(&mut self) -> io::Result<()> { in flush()
|
| H A D | errors.rs | 10 IOError(std::io::Error),
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | errors.rs | 5 fmt, {io, string},
47 BufferWriteError(io::Error),
57 impl From<io::Error> for Amf0WriteError {
58 fn from(error: io::Error) -> Self { in from()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 71 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
128 io: Arc::clone(&net_io), in new()
184 let data = self.io.lock().await.read().await?; in run()
220 let data = self.io.lock().await.read().await?; in handshake()
342 let mut netconnection = NetConnection::new(Arc::clone(&self.io)); in send_connect()
378 let mut netconnection = NetConnection::new(Arc::clone(&self.io)); in send_create_stream()
389 let mut netstream = NetStreamWriter::new(Arc::clone(&self.io)); in send_delete_stream()
403 let mut netstream = NetStreamWriter::new(Arc::clone(&self.io)); in send_publish()
419 let mut netstream = NetStreamWriter::new(Arc::clone(&self.io)); in send_play()
424 let mut netconnection = NetConnection::new(Arc::clone(&self.io)); in send_play()
[all …]
|
| H A D | server_session.rs | 53 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
85 io: Arc::clone(&net_io), in new()
128 self.bytesio_data = self.io.lock().await.read().await?; in handshake()
153 .io in read_parse_chunks()
235 ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone())); in send_set_chunk_size()
430 ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone())); in on_connect()
460 let mut netconnection = NetConnection::new(Arc::clone(&self.io)); in on_connect()
478 let mut netconnection = NetConnection::new(Arc::clone(&self.io)); in on_create_stream()
504 let mut netstream = NetStreamWriter::new(Arc::clone(&self.io)); in on_delete_stream()
601 let mut netstream = NetStreamWriter::new(Arc::clone(&self.io)); in on_play()
[all …]
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_track.rs | 124 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in on_rtcp()
126 self.rtcp_channel.lock().await.on_rtcp(reader, io).await; in on_rtcp()
129 pub async fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer()
130 self.rtp_channel.lock().await.create_packer(io); in create_packer()
|
| H A D | rtsp_channel.rs | 129 fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer()
137 io, in create_packer()
146 io, in create_packer()
154 io, in create_packer()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_aac.rs | 29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
37 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
48 io, in new()
71 f(self.io.clone(), packet).await?; in pack()
|
| H A D | rtp_h265.rs | 27 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
49 io, in new()
115 f(self.io.clone(), packet).await?; in pack_fu()
135 return f(self.io.clone(), packet).await; in pack_single()
|
| H A D | rtp_h264.rs | 29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
49 io, in new()
92 f(self.io.clone(), packet).await?; in pack_fu_a()
114 return f(self.io.clone(), packet).await; in pack_single()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_server.rs | 35 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
38 writer: AsyncBytesWriter::new(io), in new()
87 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
90 writer: AsyncBytesWriter::new(io), in new()
278 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
280 simple_handshaker: SimpleHandshakeServer::new(io.clone()), in new()
281 complex_handshaker: ComplexHandshakeServer::new(io), in new()
|
| H A D | handshake_client.rs | 25 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
28 writer: AsyncBytesWriter::new(io), in new()
|
| /xiu/library/bytesio/ |
| H A D | README.md | 1 A network bytes io library.
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 63 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
114 let io = Arc::new(Mutex::new(net_io)); in new() localVariable
117 io: io.clone(), in new()
119 writer: AsyncBytesWriter::new(io), in new()
131 let data = self.io.lock().await.read().await?; in run()
139 let data = self.io.lock().await.read().await?; in run()
168 track.on_rtcp(&mut cur_reader, self.io.clone()).await; in on_rtp_over_rtsp_message()
348 track.create_packer(self.io.clone()).await; in handle_setup()
428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
431 let mut bytes_writer = AsyncBytesWriter::new(io); in handle_play()
[all …]
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 17 use std::io::Read;
39 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
54 let io = Arc::new(Mutex::new(net_io)); in new() localVariable
57 io: io.clone(), in new()
59 writer: AsyncBytesWriter::new(io), in new()
80 let data = self.io.lock().await.read().await?; in run()
93 let data = self.io.lock().await.read().await?; in run()
|
| /xiu/application/xiu/src/config/ |
| H A D | errors.rs | 3 std::{fmt, io::Error},
|