Struct Blocking 

pub(crate) struct Blocking<T> {
    inner: Option<T>,
    state: State<T>,
    need_flush: bool,
    mandatory: bool,
}

T should not implement both Read and Write.

Fields

inner: Option<T>

state: State<T>

need_flush: bool

true if the lower IO layer needs flushing.

mandatory: bool

true if operations are spawned with spawn_mandatory_blocking.

Implementations

impl<T> Blocking<T>

pub(crate) unsafe fn new(inner: T) -> Blocking<T>

Safety

The Read implementation of inner must never read from the buffer it is borrowing and must correctly report the length of the data written into the buffer.

pub(crate) unsafe fn new_mandatory(inner: T) -> Blocking<T>

Like new, but operations are spawned with spawn_mandatory_blocking, so an operation that was started before the runtime began shutting down still runs.

Safety

Same as new.

Trait Implementations

impl<T> AsyncRead for Blocking<T>

where T: Read + Unpin + Send + 'static,

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

Attempts to read from the AsyncRead into buf.

impl<T> AsyncWrite for Blocking<T>

where T: Write + Unpin + Send + 'static,

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<(), Error>>

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<(), Error>>

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>>

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.

impl<T: Debug> Debug for Blocking<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.