Home
last modified time | relevance | path

Searched defs:TcpStream (Results 1 – 9 of 9) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
Dstream.rs28 pub struct TcpStream { struct
30 pub(crate) inner: net::TcpStream, argument
35 impl TcpStream { argument
44 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
53 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std()
262 impl fmt::Debug for TcpStream { implementation
300 impl IntoRawSocket for TcpStream { implementation
306 impl AsRawSocket for TcpStream { implementation
312 impl FromRawSocket for TcpStream { implementation
319 impl Source for TcpStream { implementation
Dlistener.rs72 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
Dstream.rs25 pub struct TcpStream { struct
27 pub inner: net::TcpStream, argument
30 impl TcpStream { implementation
33 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
39 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std()
220 impl Read for TcpStream { implementation
230 impl Write for TcpStream { implementation
244 impl Read for &TcpStream { implementation
256 impl Write for &TcpStream { implementation
273 impl std::fmt::Debug for TcpStream { implementation
[all …]
Dsocket.rs87 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect()
Dlistener.rs52 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
Dstream.rs61 pub struct TcpStream { struct
62 pub(crate) source: AsyncSource<ylong_io::TcpStream>, argument
65 impl Debug for TcpStream { implementation
71 impl TcpStream { implementation
567 impl AsyncRead for TcpStream { implementation
577 impl AsyncWrite for TcpStream { implementation
612 impl AsRawSocket for TcpStream { implementation
625 impl AsRawFd for TcpStream { implementation
Dlistener.rs99 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
Dmod.rs58 async fn tcp_stream(addr: &str) -> io::Result<TcpStream> { in tcp_stream()
175 mut conn: TcpStream, in tunnel()
179 ) -> Result<TcpStream, Error> { in tunnel()
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
Dconnector.rs143 mut conn: TcpStream, in tunnel()
147 ) -> Result<TcpStream, HttpClientError> { in tunnel()