| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_track.rs | 9 use bytesio::bytesio::TNetIO;
14 fn create_packer(&mut self, writer: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>); in create_packer()
61 pub async fn rtp_receive_loop(&mut self, mut rtp_io: Box<dyn TNetIO + Send + Sync>) { in rtp_receive_loop()
83 pub async fn rtcp_receive_loop(&mut self, rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in rtcp_receive_loop()
124 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in on_rtcp()
129 pub async fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer()
|
| H A D | rtsp_channel.rs | 32 use bytesio::bytesio::TNetIO;
38 fn create_packer(&mut self, writer: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>); in create_packer()
129 fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer()
170 rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in on_rtcp()
195 rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in send_rr()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_aac.rs | 18 use bytesio::bytesio::TNetIO;
29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
37 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
|
| H A D | utils.rs | 8 use bytesio::bytesio::TNetIO;
32 Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
|
| H A D | rtp_h265.rs | 19 use bytesio::bytesio::TNetIO;
27 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
|
| H A D | rtp_h264.rs | 19 use bytesio::bytesio::TNetIO;
29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 23 pub trait TNetIO: Send + Sync { trait
63 impl TNetIO for UdpIO {
107 impl TNetIO for TcpIO {
|
| H A D | bytes_writer.rs | 4 bytesio::TNetIO,
156 pub io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
160 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| H A D | bytes_reader.rs | 4 bytesio::TNetIO,
151 pub struct AsyncBytesReader<T1: TNetIO> {
158 T1: TNetIO,
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_client.rs | 8 bytesio::{bytes_reader::BytesReader, bytes_writer::AsyncBytesWriter, bytesio::TNetIO},
25 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| H A D | handshake_server.rs | 10 bytesio::TNetIO,
35 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
87 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
278 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | packetizer.rs | 7 bytesio::{bytes_writer::AsyncBytesWriter, bytesio::TNetIO},
31 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 41 use bytesio::bytesio::TNetIO;
63 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
113 let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
363 let box_udp_io: Box<dyn TNetIO + Send + Sync> = Box::new(rtp_io); in handle_setup()
377 let box_rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>> = in handle_setup()
428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
444 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 8 bytesio::bytesio::TNetIO,
20 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 8 bytesio::bytesio::TNetIO,
70 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 15 use bytesio::bytesio::TNetIO;
39 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
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 | 27 bytesio::{TNetIO, TcpIO},
71 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
110 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|
| H A D | server_session.rs | 28 bytesio::{TNetIO, TcpIO},
53 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
78 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
|