Struct futures_util::sink::SendAll

#[must_use = "futures do nothing unless polled"]
pub struct SendAll<T, U: Stream> { /* fields omitted */ }

Future for the Sink::send_all combinator, which sends a stream of values to a sink and then waits until the sink has fully flushed those values.

Trait Implementations

impl<T: Debug, U: Debug + Stream> Debug for SendAll<T, U> where
    U::Item: Debug, 

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T, U> Future for SendAll<T, U> where
    T: Sink,
    U: Stream<Item = T::SinkItem>,
    T::SinkError: From<U::Error>, 

type Item = (T, U)

A successful value

type Error = T::SinkError

An error

fn poll(&mut self, cx: &mut Context) -> Poll<(T, U), T::SinkError>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.