Struct ReadyStream 

pub struct ReadyStream { /* private fields */ }

A non-blocking TcpStream that reads and writes through a Poller.

Implementations

impl ReadyStream

pub fn split(self) -> (ReadHalf, WriteHalf)

Two handles to the one socket, as a connection protocol takes them: a reader and a writer that are polled by different tasks.

Splitting costs nothing at the poller: read and write are already separate interests on the same fd, each with its own waker, so the two halves park independently on the one registration they share. There is no lock between them either — the halves call read/write through &TcpStream, and the kernel already serialises those per direction.

pub fn socket(&self) -> &TcpStream

The wrapped socket, for the options a driver sets after accept (SO_SNDBUF, keepalive).

Trait Implementations

impl AsyncRead for ReadyStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for ReadyStream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, src: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.