[][src]Trait futures::sink::Sink

#[must_use = "sinks do nothing unless polled"]
pub trait Sink<Item> { type SinkError; fn poll_ready(
        self: Pin<&mut Self>,
        cx: &mut Context
    ) -> Poll<Result<(), Self::SinkError>>;
fn start_send(
        self: Pin<&mut Self>,
        item: Item
    ) -> Result<(), Self::SinkError>;
fn poll_flush(
        self: Pin<&mut Self>,
        cx: &mut Context
    ) -> Poll<Result<(), Self::SinkError>>;
fn poll_close(
        self: Pin<&mut Self>,
        cx: &mut Context
    ) -> Poll<Result<(), Self::SinkError>>; }

A Sink is a value into which other values can be sent, asynchronously.

Basic examples of sinks include the sending side of:

In addition to such "primitive" sinks, it's typical to layer additional functionality, such as buffering, on top of an existing sink.

Sending to a sink is "asynchronous" in the sense that the value may not be sent in its entirety immediately. Instead, values are sent in a two-phase way: first by initiating a send, and then by polling for completion. This two-phase setup is analogous to buffered writing in synchronous code, where writes often succeed immediately, but internally are buffered and are actually written only upon flushing.

In addition, the Sink may be full, in which case it is not even possible to start the sending process.

As with Future and Stream, the Sink trait is built from a few core required methods, and a host of default methods for working in a higher-level way. The Sink::send_all combinator is of particular importance: you can use it to send an entire stream to a sink, which is the simplest way to ultimately consume a stream.

Associated Types

type SinkError

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

Loading content...

Required methods

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

Attempts to prepare the Sink to receive a value.

This method must be called and return Poll::Ready(Ok(())) prior to each call to start_send.

This method returns Poll::Ready once the underlying sink is ready to receive data. If this method returns Poll::Pending, the current task is registered to be notified (via cx.waker().wake_by_ref()) when poll_ready should be called again.

In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.

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

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

As the name suggests, this method only begins the process of sending the item. If the sink employs buffering, the item isn't fully processed until the buffer is fully flushed. Since sinks are designed to work with asynchronous I/O, the process of actually writing out the data to an underlying object takes place asynchronously. You must use poll_flush or poll_close in order to guarantee completion of a send.

Implementations of poll_ready and start_send will usually involve flushing behind the scenes in order to make room for new messages. It is only necessary to call poll_flush if you need to guarantee that all of the items placed into the Sink have been sent.

In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.

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

Flush any remaining output from this sink.

Returns Poll::Ready(Ok(())) when no buffered items remain. If this value is returned then it is guaranteed that all previous values sent via start_send have been flushed.

Returns Poll::Pending if there is more work left to do, in which case the current task is scheduled (via cx.waker().wake_by_ref()) to wake up when poll_flush should be called again.

In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.

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

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

Returns Poll::Ready(Ok(())) when no buffered items remain and the sink has been successfully closed.

Returns Poll::Pending if there is more work left to do, in which case the current task is scheduled (via cx.waker().wake_by_ref()) to wake up when poll_close should be called again.

If this function encounters an error, the sink should be considered to have failed permanently, and no more Sink methods should be called.

Loading content...

Implementations on Foreign Types

impl<S, Fut, F, Item> Sink<Item> for TryFilter<S, Fut, F> where
    F: FnMut(&<S as TryStream>::Ok) -> Fut,
    Fut: Future<Output = bool>,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<P, Item> Sink<Item> for Pin<P> where
    P: DerefMut + Unpin,
    <P as Deref>::Target: Sink<Item>, 
[src]

type SinkError = <<P as Deref>::Target as Sink<Item>>::SinkError

impl<'_, S, Item> Sink<Item> for &'_ mut S where
    S: Sink<Item> + Unpin + ?Sized
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Box<S> where
    S: Sink<Item> + Unpin + ?Sized
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<T> Sink<T> for VecDeque<T>[src]

type SinkError = VecSinkError

impl<T> Sink<T> for Vec<T>[src]

type SinkError = VecSinkError

Loading content...

Implementors

impl<'_, T> Sink<T> for &'_ UnboundedSender<T>[src]

type SinkError = SendError

impl<A, B, Item> Sink<Item> for Either<A, B> where
    A: Sink<Item>,
    B: Sink<Item, SinkError = <A as Sink<Item>>::SinkError>, 
[src]

type SinkError = <A as Sink<Item>>::SinkError

impl<Fut, Si, Item> Sink<Item> for FlattenSink<Fut, Si> where
    Fut: TryFuture<Ok = Si>,
    Si: Sink<Item, SinkError = <Fut as TryFuture>::Error>, 
[src]

type SinkError = <Si as Sink<Item>>::SinkError

impl<S, E, Item> Sink<Item> for ErrInto<S, E> where
    S: TryStream + Sink<Item>,
    <S as TryStream>::Error: Into<E>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, E, Item> Sink<Item> for MapErr<S, F> where
    F: FnMut(<S as TryStream>::Error) -> E,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, Item> Sink<Item> for Inspect<S, F> where
    F: FnMut(&<S as Stream>::Item),
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, Item> Sink<Item> for InspectErr<S, F> where
    F: FnMut(&<S as TryStream>::Error),
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, Item> Sink<Item> for InspectOk<S, F> where
    F: FnMut(&<S as TryStream>::Ok),
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, T, Item> Sink<Item> for Map<S, F> where
    F: FnMut(<S as Stream>::Item) -> T,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, F, T, Item> Sink<Item> for MapOk<S, F> where
    F: FnMut(<S as TryStream>::Ok) -> T,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for AndThen<S, Fut, F> where
    F: FnMut(<S as TryStream>::Ok) -> Fut,
    Fut: TryFuture<Error = <S as TryStream>::Error>,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for Filter<S, Fut, F> where
    F: FnMut(&<S as Stream>::Item) -> Fut,
    Fut: Future<Output = bool>,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for FilterMap<S, Fut, F> where
    F: FnMut(<S as Stream>::Item) -> Fut,
    Fut: Future,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for OrElse<S, Fut, F> where
    F: FnMut(<S as TryStream>::Error) -> Fut,
    Fut: TryFuture<Ok = <S as TryStream>::Ok>,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for SkipWhile<S, Fut, F> where
    F: FnMut(&<S as Stream>::Item) -> Fut,
    Fut: Future<Output = bool>,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for TakeWhile<S, Fut, F> where
    F: FnMut(&<S as Stream>::Item) -> Fut,
    Fut: Future<Output = bool>,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for Then<S, Fut, F> where
    F: FnMut(<S as Stream>::Item) -> Fut,
    Fut: Future,
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, Item> Sink<Item> for TrySkipWhile<S, Fut, F> where
    F: FnMut(&<S as TryStream>::Ok) -> Fut,
    Fut: TryFuture<Ok = bool, Error = <S as TryStream>::Error>,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Fut, F, T, Item> Sink<Item> for TryFilterMap<S, Fut, F> where
    F: FnMut(<S as TryStream>::Ok) -> Fut,
    Fut: TryFuture<Ok = Option<T>, Error = <S as TryStream>::Error>,
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for BufferUnordered<S> where
    S: Stream + Sink<Item>,
    <S as Stream>::Item: Future
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Buffered<S> where
    S: Stream + Sink<Item>,
    <S as Stream>::Item: Future
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Chunks<S> where
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Enumerate<S> where
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Flatten<S> where
    S: Stream + Sink<Item>,
    <S as Stream>::Item: Stream
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Fuse<S> where
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for IntoStream<S> where
    S: TryStream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Peekable<S> where
    S: Sink<Item> + Stream
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Skip<S> where
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for SplitSink<S, Item> where
    S: Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for Take<S> where
    S: Stream + Sink<Item>, 
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, Item> Sink<Item> for TryBufferUnordered<S> where
    S: TryStream + Sink<Item>,
    <S as TryStream>::Ok: TryFuture,
    <<S as TryStream>::Ok as TryFuture>::Error == <S as TryStream>::Error
[src]

type SinkError = <S as Sink<Item>>::SinkError

impl<S, SinkItem> Sink<SinkItem> for Compat01As03Sink<S, SinkItem> where
    S: Sink<SinkItem = SinkItem>, 
[src]

type SinkError = <S as Sink>::SinkError

impl<Si, F, E, Item> Sink<Item> for SinkMapErr<Si, F> where
    F: FnOnce(<Si as Sink<Item>>::SinkError) -> E,
    Si: Sink<Item>, 
[src]

type SinkError = E

impl<Si, Item> Sink<Item> for Buffer<Si, Item> where
    Si: Sink<Item>, 
[src]

type SinkError = <Si as Sink<Item>>::SinkError

impl<Si, Item, E> Sink<Item> for SinkErrInto<Si, Item, E> where
    Si: Sink<Item>,
    <Si as Sink<Item>>::SinkError: Into<E>, 
[src]

type SinkError = E

impl<Si, Item, U, Fut, F, E> Sink<U> for With<Si, Item, U, Fut, F> where
    E: From<<Si as Sink<Item>>::SinkError>,
    F: FnMut(U) -> Fut,
    Fut: Future<Output = Result<Item, E>>,
    Si: Sink<Item>, 
[src]

type SinkError = E

impl<Si, Item, U, St, F> Sink<U> for WithFlatMap<Si, Item, U, St, F> where
    F: FnMut(U) -> St,
    Si: Sink<Item>,
    St: Stream<Item = Result<Item, <Si as Sink<Item>>::SinkError>>, 
[src]

type SinkError = <Si as Sink<Item>>::SinkError

impl<Si1, Si2, Item> Sink<Item> for Fanout<Si1, Si2> where
    Item: Clone,
    Si1: Sink<Item>,
    Si2: Sink<Item, SinkError = <Si1 as Sink<Item>>::SinkError>, 
[src]

type SinkError = <Si1 as Sink<Item>>::SinkError

impl<T> Sink<T> for Sender<T>[src]

type SinkError = SendError

impl<T> Sink<T> for UnboundedSender<T>[src]

type SinkError = SendError

impl<T> Sink<T> for Drain<T>[src]

type SinkError = DrainError

Loading content...