[−][src]Enum tcp_stream::TcpStream
Wrapper around plain or TLS TCP streams
Variants
Plain(MioTcpStream)
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
Methods
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 from_std(stream: TcpStream) -> Self
[src]
Wrapper around mio's TcpStream::from_std
pub fn into_tls(
self,
domain: &str,
identity: Option<Identity>
) -> Result<Self, HandshakeError>
[src]
self,
domain: &str,
identity: Option<Identity>
) -> 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.
fn deref(&self) -> &Self::Target
[src]
impl DerefMut for TcpStream
[src]
impl From<SslStream<TcpStream>> for TcpStream
[src]
fn from(s: OpenSslStream) -> Self
[src]
impl From<StreamOwned<ClientSession, TcpStream>> for TcpStream
[src]
fn from(s: RustlsStream) -> Self
[src]
impl From<TcpStream> for TcpStream
[src]
fn from(s: MioTcpStream) -> Self
[src]
impl From<TlsStream<TcpStream>> for TcpStream
[src]
fn from(s: NativeTlsStream) -> Self
[src]
impl FromRawFd for TcpStream
[src]
unsafe fn from_raw_fd(fd: RawFd) -> Self
[src]
impl Read for TcpStream
[src]
fn read(&mut self, buf: &mut [u8]) -> Result<usize>
[src]
fn read_vectored(&mut self, bufs: &mut [IoSliceMut]) -> Result<usize>
[src]
fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize>
[src]
fn read_to_string(&mut self, buf: &mut String) -> Result<usize>
[src]
fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>
[src]
unsafe fn initializer(&self) -> Initializer
[src]
fn by_ref(&mut self) -> &mut Self
1.0.0[src]
fn bytes(self) -> Bytes<Self>
1.0.0[src]
fn chain<R>(self, next: R) -> Chain<Self, R> where
R: Read,
1.0.0[src]
R: Read,
fn take(self, limit: u64) -> Take<Self>
1.0.0[src]
impl Source for TcpStream
[src]
fn register(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
fn reregister(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<()>
fn deregister(&mut self, registry: &Registry) -> Result<()>
[src]
impl Write for TcpStream
[src]
fn write(&mut self, buf: &[u8]) -> Result<usize>
[src]
fn flush(&mut self) -> Result<()>
[src]
fn write_vectored(&mut self, bufs: &[IoSlice]) -> Result<usize>
[src]
fn write_all(&mut self, buf: &[u8]) -> Result<()>
[src]
fn write_fmt(&mut self, fmt: Arguments) -> Result<()>
[src]
fn write_all_vectored(&mut self, bufs: &mut [IoSlice]) -> Result<(), Error>
[src]
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,
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, 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.
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>,