Struct AsyncWriteStream 

pub struct AsyncWriteStream<S> { /* private fields */ }

Available on crate features io and compat only.

A write stream wrapper for [futures_util::io].

It doesn’t support read operations, making looser requirements on the inner stream.

Implementations

impl<S> AsyncWriteStream<S>

pub fn new(stream: S) -> AsyncWriteStream<S>

Create AsyncWriteStream with the stream and default buffer size.

pub fn with_capacity(cap: usize, stream: S) -> AsyncWriteStream<S>

Create AsyncWriteStream with the stream and buffer size.

pub fn get_ref(&self) -> &S

Get the reference of the inner stream.

pub fn get_mut(&mut self) -> &mut S

Returns a mutable reference to the underlying stream.

pub fn into_inner(self) -> S

Consumes the SyncStream, returning the underlying stream.

Trait Implementations

impl<S> AsyncWrite for AsyncWriteStream<S>

where S: AsyncWrite + Unpin + 'static,

fn poll_write( self: Pin<&mut AsyncWriteStream<S>>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut AsyncWriteStream<S>>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

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

fn poll_close( self: Pin<&mut AsyncWriteStream<S>>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to close the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<'__pin, S> Unpin for AsyncWriteStream<S>

where <PinnedFieldsOfHelperStruct<__Origin<'__pin, S>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,