[−][src]Enum amq_protocol_tcp::TcpStream
Re-export TcpStream Wrapper around plain or TLS TCP streams
Variants
Plain(TcpStream)
Wrapper around mio's TcpStream
Wrapper around a TLS stream hanled by native-tls
Methods
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
ⓘImportant traits for TcpStreampub fn from_std(stream: TcpStream) -> TcpStream
[src]
Wrapper around mio's TcpStream::from_std
pub fn into_tls(
self,
domain: &str,
identity: Option<Identity>
) -> Result<TcpStream, HandshakeError>
[src]
self,
domain: &str,
identity: Option<Identity>
) -> 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
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 AsRawFd for TcpStream
[src]
impl Debug for TcpStream
[src]
impl Deref for TcpStream
[src]
type Target = TcpStream
The resulting type after dereferencing.
ⓘImportant traits for TcpStreamfn deref(&self) -> &<TcpStream as Deref>::Target
[src]
impl DerefMut for TcpStream
[src]
impl From<TcpStream> for TcpStream
[src]
impl From<TlsStream<TcpStream>> for TcpStream
[src]
impl FromRawFd for TcpStream
[src]
ⓘImportant traits for TcpStreamunsafe fn from_raw_fd(fd: i32) -> 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>
1.36.0[src]
unsafe fn initializer(&self) -> Initializer
[src]
fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
1.0.0[src]
fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
1.0.0[src]
fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
1.6.0[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 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>
1.36.0[src]
fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
1.0.0[src]
fn write_fmt(&mut self, fmt: Arguments) -> Result<(), Error>
1.0.0[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>,