Enum amq_protocol_tcp::TcpStream [−][src]
Re-export TcpStream Wrapper around plain or TLS TCP streams
Variants
Wrapper around mio’s TcpStream
Wrapper around a TLS stream hanled by native-tls
Implementations
impl TcpStream
[src]
Re-export TcpStream
pub fn connect<A>(addr: A) -> Result<TcpStream, Error> where
A: ToSocketAddrs,
[src]
A: ToSocketAddrs,
Wrapper around mio’s TcpStream::connect inspired by std::net::TcpStream::connect
pub fn connect_timeout<A>(
addr: A,
timeout: Duration
) -> Result<TcpStream, Error> where
A: ToSocketAddrs,
[src]
addr: A,
timeout: Duration
) -> Result<TcpStream, Error> where
A: ToSocketAddrs,
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: TcpStream) -> Result<TcpStream, Error>
[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, Error>
[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<TcpStream, HandshakeError>
[src]
self,
domain: &str,
config: TLSConfig<'_, '_, '_>
) -> Result<TcpStream, HandshakeError>
Enable TLS
pub fn into_native_tls(
self,
connector: TlsConnector,
domain: &str
) -> Result<TcpStream, HandshakeError>
[src]
self,
connector: TlsConnector,
domain: &str
) -> Result<TcpStream, HandshakeError>
Enable TLS using native-tls
impl TcpStream
[src]
Re-export TcpStream
pub fn is_readable(&self) -> Result<(), Error>
[src]
Attempt reading from underlying stream, returning Ok(()) if the stream is readable
pub fn is_writable(&self) -> Result<(), Error>
[src]
Attempt writing to underlying stream, returning Ok(()) if the stream is writable
Methods from Deref<Target = TcpStream>
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 AsRawSocket for TcpStream
[src]
pub fn as_raw_socket(&self) -> u64
[src]
impl<'_> AsRawSocket for &'_ TcpStream
[src]
pub fn as_raw_socket(&self) -> u64
[src]
impl Debug for TcpStream
[src]
impl Deref for TcpStream
[src]
type Target = TcpStream
The resulting type after dereferencing.
pub fn deref(&self) -> &<TcpStream as Deref>::Targetⓘ
[src]
impl DerefMut for TcpStream
[src]
impl From<TcpStream> for MidHandshakeTlsStream
[src]
pub fn from(mid: TcpStream) -> MidHandshakeTlsStream
[src]
impl From<TlsStream<TcpStream>> for TcpStream
[src]
impl FromRawSocket for TcpStream
[src]
pub unsafe fn from_raw_socket(socket: u64) -> TcpStreamⓘ
[src]
impl Read for TcpStream
[src]
pub fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error>
[src]
pub fn read_vectored(
&mut self,
bufs: &mut [IoSliceMut<'_>]
) -> Result<usize, Error>
[src]
&mut self,
bufs: &mut [IoSliceMut<'_>]
) -> Result<usize, Error>
pub fn read_to_end(&mut self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>
[src]
pub fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
[src]
pub fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
[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<(), Error>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
pub fn reregister(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
pub fn deregister(&mut self, registry: &Registry) -> Result<(), Error>
[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: TcpStream) -> Result<TcpStream, Error>
[src]
impl Write for TcpStream
[src]
pub fn write(&mut self, buf: &[u8]) -> Result<usize, Error>
[src]
pub fn flush(&mut self) -> Result<(), Error>
[src]
pub fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>
[src]
pub fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
[src]
pub fn write_fmt(&mut self, fmt: Arguments<'_>) -> Result<(), Error>
[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> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[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.
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>,