[−][src]Enum tcp_stream::TcpStream
Wrapper around plain or TLS TCP streams
Variants
Plain(MioTcpStream, bool)
Wrapper around mio's TcpStream
NativeTls(Box<NativeTlsStream>)
Wrapper around a TLS stream hanled by native-tls
OpenSsl(Box<OpenSslStream>)
Wrapper around a TLS stream hanled by openssl
Rustls(Box<RustlsStream>)
Wrapper around a TLS stream hanled by rustls
Implementations
impl TcpStream
[src]
pub fn connect<A: ToSocketAddrs>(addr: A) -> Result<Self>
[src]
Wrapper around mio's TcpStream::connect inspired by std::net::TcpStream::connect
pub fn connect_timeout<A: ToSocketAddrs>(
addr: A,
timeout: Duration
) -> Result<Self>
[src]
addr: A,
timeout: Duration
) -> Result<Self>
Wrapper around mio's TcpStream::connect inspired by std::net::TcpStream::connect_timeout and std::net::TcpStream::connect. We used the timeout on the first SocketAddr.
pub fn from_std(stream: StdTcpStream) -> Result<Self>
[src]
Wrapper around mio's TcpStream::from_std
pub fn is_connected(&self) -> bool
[src]
Check whether the stream is connected or not
pub fn try_connect(&mut self) -> Result<bool>
[src]
Retry the connection. Returns:
- Ok(true) if connected
- Ok(false) if connecting
- Err(_) if an error is encountered
pub fn into_tls(
self,
domain: &str,
config: TLSConfig<'_, '_, '_>
) -> Result<Self, HandshakeError>
[src]
self,
domain: &str,
config: TLSConfig<'_, '_, '_>
) -> Result<Self, HandshakeError>
Enable TLS
pub fn into_native_tls(
self,
connector: NativeTlsConnector,
domain: &str
) -> Result<Self, HandshakeError>
[src]
self,
connector: NativeTlsConnector,
domain: &str
) -> Result<Self, HandshakeError>
Enable TLS using native-tls
pub fn into_openssl(
self,
connector: OpenSslConnector,
domain: &str
) -> Result<Self, HandshakeError>
[src]
self,
connector: OpenSslConnector,
domain: &str
) -> Result<Self, HandshakeError>
Enable TLS using openssl
pub fn into_rustls(
self,
connector: RustlsConnector,
domain: &str
) -> Result<Self, HandshakeError>
[src]
self,
connector: RustlsConnector,
domain: &str
) -> Result<Self, HandshakeError>
Enable TLS using rustls
impl TcpStream
[src]
pub fn is_readable(&self) -> Result<()>
[src]
Attempt reading from underlying stream, returning Ok(()) if the stream is readable
pub fn is_writable(&self) -> Result<()>
[src]
Attempt writing to underlying stream, returning Ok(()) if the stream is writable
Methods from Deref<Target = MioTcpStream>
pub fn peer_addr(&self) -> Result<SocketAddr, Error>
[src]
Returns the socket address of the remote peer of this TCP connection.
pub fn local_addr(&self) -> Result<SocketAddr, Error>
[src]
Returns the socket address of the local half of this TCP connection.
pub fn shutdown(&self, how: Shutdown) -> Result<(), Error>
[src]
Shuts down the read, write, or both halves of this connection.
This function will cause all pending and future I/O on the specified
portions to return immediately with an appropriate value (see the
documentation of Shutdown
).
pub fn set_nodelay(&self, nodelay: bool) -> Result<(), Error>
[src]
Sets the value of the TCP_NODELAY
option on this socket.
If set, this option disables the Nagle algorithm. This means that segments are always sent as soon as possible, even if there is only a small amount of data. When not set, data is buffered until there is a sufficient amount to send out, thereby avoiding the frequent sending of small packets.
Notes
On Windows make sure the stream is connected before calling this method,
by receiving an (writable) event. Trying to set nodelay
on an
unconnected TcpStream
is undefined behavior.
pub fn nodelay(&self) -> Result<bool, Error>
[src]
Gets the value of the TCP_NODELAY
option on this socket.
For more information about this option, see set_nodelay
.
Notes
On Windows make sure the stream is connected before calling this method,
by receiving an (writable) event. Trying to get nodelay
on an
unconnected TcpStream
is undefined behavior.
pub fn set_ttl(&self, ttl: u32) -> Result<(), Error>
[src]
Sets the value for the IP_TTL
option on this socket.
This value sets the time-to-live field that is used in every packet sent from this socket.
Notes
On Windows make sure the stream is connected before calling this method,
by receiving an (writable) event. Trying to set ttl
on an
unconnected TcpStream
is undefined behavior.
pub fn ttl(&self) -> Result<u32, Error>
[src]
Gets the value of the IP_TTL
option for this socket.
For more information about this option, see set_ttl
.
Notes
On Windows make sure the stream is connected before calling this method,
by receiving an (writable) event. Trying to get ttl
on an
unconnected TcpStream
is undefined behavior.
pub fn take_error(&self) -> Result<Option<Error>, Error>
[src]
Get the value of the SO_ERROR
option on this socket.
This will retrieve the stored error in the underlying socket, clearing the field in the process. This can be useful for checking errors between calls.
pub fn peek(&self, buf: &mut [u8]) -> Result<usize, Error>
[src]
Receives data on the socket from the remote address to which it is connected, without removing that data from the queue. On success, returns the number of bytes peeked.
Successive calls return the same data. This is accomplished by passing
MSG_PEEK
as a flag to the underlying recv system call.
Trait Implementations
impl AsRawFd for TcpStream
[src]
impl<'_> AsRawFd for &'_ TcpStream
[src]
impl Debug for TcpStream
[src]
impl Deref for TcpStream
[src]
type Target = MioTcpStream
The resulting type after dereferencing.
pub fn deref(&self) -> &Self::Target
[src]
impl DerefMut for TcpStream
[src]
impl From<SslStream<TcpStream>> for TcpStream
[src]
pub fn from(s: OpenSslStream) -> Self
[src]
impl From<StreamOwned<ClientSession, TcpStream>> for TcpStream
[src]
pub fn from(s: RustlsStream) -> Self
[src]
impl From<TcpStream> for MidHandshakeTlsStream
[src]
impl From<TlsStream<TcpStream>> for TcpStream
[src]
pub fn from(s: NativeTlsStream) -> Self
[src]
impl FromRawFd for TcpStream
[src]
pub unsafe fn from_raw_fd(fd: RawFd) -> Self
[src]
impl Read for TcpStream
[src]
pub fn read(&mut self, buf: &mut [u8]) -> Result<usize>
[src]
pub fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
[src]
pub fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize>
[src]
pub fn read_to_string(&mut self, buf: &mut String) -> Result<usize>
[src]
pub fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>
[src]
pub fn is_read_vectored(&self) -> bool
[src]
pub unsafe fn initializer(&self) -> Initializer
[src]
pub fn by_ref(&mut self) -> &mut Self
1.0.0[src]
pub fn bytes(self) -> Bytes<Self>
1.0.0[src]
pub fn chain<R>(self, next: R) -> Chain<Self, R> where
R: Read,
1.0.0[src]
R: Read,
pub fn take(self, limit: u64) -> Take<Self>
1.0.0[src]
impl Source for TcpStream
[src]
pub fn register(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
pub fn reregister(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
pub fn deregister(&mut self, registry: &Registry) -> Result<()>
[src]
impl TryFrom<TcpStream> for TcpStream
[src]
type Error = Error
The type returned in the event of a conversion error.
pub fn try_from(s: MioTcpStream) -> Result<Self>
[src]
impl Write for TcpStream
[src]
pub fn write(&mut self, buf: &[u8]) -> Result<usize>
[src]
pub fn flush(&mut self) -> Result<()>
[src]
pub fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize>
[src]
pub fn write_all(&mut self, buf: &[u8]) -> Result<()>
[src]
pub fn write_fmt(&mut self, fmt: Arguments<'_>) -> Result<()>
[src]
pub fn is_write_vectored(&self) -> bool
[src]
pub fn write_all_vectored(
&mut self,
bufs: &mut [IoSlice<'_>]
) -> Result<(), Error>
[src]
&mut self,
bufs: &mut [IoSlice<'_>]
) -> Result<(), Error>
pub fn by_ref(&mut self) -> &mut Self
1.0.0[src]
Auto Trait Implementations
impl !RefUnwindSafe for TcpStream
impl Send for TcpStream
impl Sync for TcpStream
impl Unpin for TcpStream
impl !UnwindSafe for TcpStream
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,