Struct futures_util::io::IntoSink

pub struct IntoSink<W, Item> {
    writer: W,
    buffer: Option<Block<Item>>,
}

Sink for the into_sink method.

Fields

writer: W

buffer: Option<Block<Item>>

Implementations

impl<W: AsyncWrite, Item: AsRef<[u8]>> IntoSink<W, Item>

pub(super) fn new(writer: W) -> Self

fn poll_flush_buffer( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

If we have an outstanding block in buffer attempt to push it into the writer, does not flush the writer after it succeeds in pushing the block into it.

Trait Implementations

impl<W: Debug, Item: Debug> Debug for IntoSink<W, Item>

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

Formats the value using the given formatter.

impl<W: AsyncWrite, Item: AsRef<[u8]>> Sink<Item> for IntoSink<W, Item>

type Error = Error

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

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

Flush any remaining output from this sink.

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

Flush any remaining output and close this sink, if necessary.

impl<'__pin, W, Item> Unpin for IntoSink<W, Item>

where PinnedFieldsOf<__Origin<'__pin, W, Item>>: Unpin,