Struct amq_protocol_tcp::TcpStreamWrapper

pub struct TcpStreamWrapper(_);

Unsafe wrapper "Cloning" the TcpStream but not closing it on drop.

Implementations

impl TcpStreamWrapper

pub unsafe fn new(socket: &TcpStream) -> Self

Clone the TcpStream. Original one needs to last at least for the same lifetime.

Safety

The inner TcpStream won't be closed on drop and the original one needs to live longer

Methods from Deref<Target = TcpStream>

pub fn is_connected(&self) -> bool

Check whether the stream is connected or not

pub fn try_connect(&mut self) -> Result<bool, Error>

Retry the connection. Returns:

• Ok(true) if connected
• Ok(false) if connecting
• Err(_) if an error is encountered

pub fn is_readable(&self) -> Result<(), Error>

Attempt reading from underlying stream, returning Ok(()) if the stream is readable

pub fn is_writable(&self) -> Result<(), Error>

Attempt writing to underlying stream, returning Ok(()) if the stream is writable

Trait Implementations

impl AsRawFd for TcpStreamWrapper

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Deref for TcpStreamWrapper

type Target = TcpStream

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for TcpStreamWrapper

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.