| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/tcp/ |
| D | mod.rs | 22 mod stream; module
|
| D | listener.rs | 56 let stream = match syscall!(accept4( in accept() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | mod.rs | 17 mod stream; module
|
| D | listener.rs | 104 let stream = TcpStream::new(stream)?; in accept() localVariable
|
| D | stream.rs | 96 let stream = super::super::addr::each_addr(addr, ylong_io::TcpStream::connect).await?; in connect() localVariable
101 let stream = TcpStream::new(stream)?; in connect_inner() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | mod.rs | 20 mod stream; module
|
| D | stream.rs | 44 let stream = unsafe { TcpStream::from_raw_socket(socket.as_raw_socket() as _) }; in connect() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| D | ylong_io_tcp_client.rs | 27 let mut stream = match TcpStream::connect(addr) { in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | wrapper.rs | 23 pub(crate) stream: S, field
36 let stream = Pin::new_unchecked(&mut self.stream); in inner() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | mod.rs | 19 mod stream; module
|
| D | ssl_base.rs | 60 let mut stream = SslStream::new_base(self, stream)?; in connect() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_tcp_client_perf.rs | 25 let mut stream = match TcpStream::connect(addr).await { in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 196 let mut stream = tokio_openssl::SslStream::new(ssl, stream).expect("SslStream Error"); localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | connector.rs | 133 let stream = tls_ssl.into_inner().connect(tcp_stream).map_err(|e| { in connect() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | connector.rs | 156 let mut stream = config in connect() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | mod.rs | 385 pub fn stream<T: AsyncRead + Send + Sync + 'static>(mut self, body: T) -> Self { in stream() method
490 fn stream(reader: Pin<Box<dyn AsyncRead + Send + Sync>>) -> Self { in stream() method
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | bio.rs | 129 pub(crate) stream: S, field
|