Searched refs:TcpStream (Results 1 – 8 of 8) sorted by relevance
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 7 tokio::net::TcpStream,
47 let stream = TcpStream::connect(self.address.clone()).await?; in run()
|
| H A D | push_client.rs | 8 tokio::net::TcpStream,
50 let stream = TcpStream::connect(self.address.clone()).await?; in run()
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 10 tokio::net::TcpStream,
62 let stream1 = TcpStream::connect(pull_parser.raw_domain_name.clone()).await?; in main()
86 let stream2 = TcpStream::connect(push_parser.raw_domain_name.clone()).await?; in main()
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 10 use tokio::net::TcpStream;
93 stream: Framed<TcpStream, BytesCodec>,
98 pub fn new(stream: TcpStream) -> Self { in new()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 19 use tokio::net::TcpStream;
52 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new() argument
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 35 tokio::{net::TcpStream, sync::Mutex},
95 stream: TcpStream, in new() argument
|
| H A D | server_session.rs | 36 tokio::{net::TcpStream, sync::Mutex},
70 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new() argument
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 59 use tokio::net::TcpStream;
105 pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self { in new() argument
|