[−][src]Enum amq_protocol_tcp::TcpStream
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]
fn as_raw_socket(&self) -> u32
[src]
impl<'_> AsRawSocket for &'_ TcpStream
[src]
fn as_raw_socket(&self) -> u32
[src]
impl Debug for TcpStream
[src]
impl Deref for TcpStream
[src]
type Target = TcpStream
The resulting type after dereferencing.
fn deref(&self) -> &<TcpStream as Deref>::Target
[src]
impl DerefMut for TcpStream
[src]
impl From<TlsStream<TcpStream>> for TcpStream
[src]
impl FromRawSocket for TcpStream
[src]
unsafe fn from_raw_socket(socket: u32) -> TcpStream
[src]
impl Read for TcpStream
[src]
fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error>
[src]
fn read_vectored(&mut self, bufs: &mut [IoSliceMut]) -> Result<usize, Error>
[src]
fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
[src]
fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
[src]
fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
[src]
fn is_read_vectored(&self) -> bool
[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<(), Error>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
fn reregister(
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
[src]
&mut self,
registry: &Registry,
token: Token,
interests: Interest
) -> Result<(), Error>
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.
fn try_from(s: TcpStream) -> Result<TcpStream, Error>
[src]
impl Write for TcpStream
[src]
fn write(&mut self, buf: &[u8]) -> Result<usize, Error>
[src]
fn flush(&mut self) -> Result<(), Error>
[src]
fn write_vectored(&mut self, bufs: &[IoSlice]) -> Result<usize, Error>
[src]
fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
[src]
fn write_fmt(&mut self, fmt: Arguments) -> Result<(), Error>
[src]
fn is_write_vectored(&self) -> bool
[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>,