| /external/rust/android-crates-io/crates/mio/src/net/tcp/ |
| D | stream.rs | 52 pub struct TcpStream { struct
53 inner: IoSource<net::TcpStream>, argument
56 impl TcpStream { impl
91 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
113 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std()
277 impl Read for TcpStream { implementation
287 impl<'a> Read for &'a TcpStream { implementation
297 impl Write for TcpStream { implementation
311 impl<'a> Write for &'a TcpStream { implementation
325 impl event::Source for TcpStream { implementation
[all …]
|
| D | listener.rs | 105 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/tokio/src/net/tcp/ |
| D | stream.rs | 74 impl TcpStream { implementation
159 pub(crate) fn new(connected: mio::net::TcpStream) -> io::Result<TcpStream> { in new()
202 pub fn from_std(stream: std::net::TcpStream) -> io::Result<TcpStream> { in from_std()
246 pub fn into_std(self) -> io::Result<std::net::TcpStream> { in into_std()
1311 impl TryFrom<std::net::TcpStream> for TcpStream { implementation
1325 impl AsyncRead for TcpStream { implementation
1335 impl AsyncWrite for TcpStream { implementation
1368 impl fmt::Debug for TcpStream { implementation
1379 impl AsRawFd for TcpStream { implementation
1385 impl AsFd for TcpStream { implementation
[all …]
|
| D | split_owned.rs | 74 ) -> Result<TcpStream, ReuniteError> { in reunite()
107 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite()
349 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite()
498 fn as_ref(&self) -> &TcpStream { in as_ref()
504 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| D | listener.rs | 160 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
177 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(TcpStream, SocketAddr)>> { in poll_accept()
|
| D | split.rs | 414 fn as_ref(&self) -> &TcpStream { in as_ref()
420 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| /external/rust/android-crates-io/crates/mio/src/sys/windows/ |
| D | tcp.rs | 29 pub(crate) fn connect(socket: &net::TcpStream, addr: SocketAddr) -> io::Result<()> { in connect()
62 pub(crate) fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/mio/src/sys/shell/ |
| D | tcp.rs | 15 pub(crate) fn connect(_: &net::TcpStream, _: SocketAddr) -> io::Result<()> { in connect()
29 pub(crate) fn accept(_: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/mio/src/sys/unix/ |
| D | tcp.rs | 28 pub(crate) fn connect(socket: &net::TcpStream, addr: SocketAddr) -> io::Result<()> { in connect()
59 pub(crate) fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/gdbstub/src/conn/impls/ |
| D | tcpstream.rs | 5 impl Connection for TcpStream { implementation
32 impl ConnectionExt for TcpStream { implementation
|
| /external/rust/android-crates-io/crates/tungstenite/src/ |
| D | client.rs | 48 ) -> Result<(WebSocket<MaybeTlsStream<TcpStream>>, Response)> { in connect_with_config()
52 ) -> Result<(WebSocket<MaybeTlsStream<TcpStream>>, Response)> { in connect_with_config()
127 ) -> Result<(WebSocket<MaybeTlsStream<TcpStream>>, Response)> { in connect()
131 fn connect_to_some(addrs: &[SocketAddr], uri: &Uri) -> Result<TcpStream> { in connect_to_some()
|
| D | stream.rs | 36 impl NoDelay for TcpStream { implementation
|
| /external/rust/crates/openssl/src/ssl/test/ |
| D | server.rs | 42 pub fn connect_tcp(&self) -> TcpStream { in connect_tcp()
123 pub fn connect(self) -> SslStream<TcpStream> { in connect()
156 pub fn connect(self) -> SslStream<TcpStream> { in connect()
|
| /external/rust/android-crates-io/crates/tokio/docs/ |
| D | reactor-refactor.md | 257 ### Removing all the `split()` functions
|
| /external/rust/android-crates-io/crates/tokio-stream/src/wrappers/ |
| D | tcp_listener.rs | 35 ) -> Poll<Option<io::Result<TcpStream>>> { in poll_next()
|
| /external/rust/android-crates-io/crates/mio/examples/ |
| D | tcp_server.rs | 110 connection: &mut TcpStream, in handle_connection_event()
|
| D | tcp_listenfd_server.rs | 128 connection: &mut TcpStream, in handle_connection_event()
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 28 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 29 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | io_copy_bidirectional.rs | 40 F: FnMut(JoinHandle<io::Result<(u64, u64)>>, TcpStream, TcpStream) -> Fut, in symmetric() argument
|
| /external/python/bumble/rust/src/cli/l2cap/ |
| D | client_bridge.rs | 110 tcp_stream: TcpStream, in proxy_data_between_tcp_and_l2cap()
|
| /external/rust/android-crates-io/crates/hyper/src/client/connect/ |
| D | http.rs | 326 async fn call_async(&mut self, dst: Uri) -> Result<TcpStream, ConnectError> { in call_async()
361 impl Connection for TcpStream { implementation
539 async fn connect(&mut self, config: &Config) -> Result<TcpStream, ConnectError> { in connect()
681 async fn connect(mut self) -> Result<TcpStream, ConnectError> { in connect()
|
| /external/rust/android-crates-io/crates/tonic/src/transport/server/ |
| D | conn.rs | 100 impl Connected for TcpStream { implementation
|
| /external/rust/android-crates-io/crates/hyper/src/server/ |
| D | tcp.rs | 322 tcp: TcpStream, in new()
347 pub fn into_inner(self) -> TcpStream { in into_inner()
|
| /external/crosvm/base/src/sys/unix/ |
| D | descriptor.rs | 147 impl From<SafeDescriptor> for TcpStream { implementation
|