Struct futures::sink::SendAll

[+] Show declaration

[+] Expand attributes
#[must_use = "futures do nothing unless polled"]
pub struct SendAll<'a, Si, St> where
    Si: Sink + Unpin + 'a + ?Sized,
    St: Stream + Unpin + 'a + ?Sized,  { /* fields omitted */ }

[−] Expand description

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<'a, Si, St> Unpin for SendAll<'a, Si, St> where     Si: Sink + Unpin + 'a + ?Sized,     St: Stream + Unpin + 'a + ?Sized,

impl<'a, Si, St> Debug for SendAll<'a, Si, St> where     Si: Debug + Sink + Unpin + 'a + ?Sized,     St: Debug + Stream + Unpin + 'a + ?Sized,     <Si as Sink>::SinkItem: Debug,

[+]

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

[−]

Formats the value using the given formatter.

impl<'a, Si, St> Future for SendAll<'a, Si, St> where     Si: Unpin + 'a + Sink + ?Sized,     St: Stream<Item = <Si as Sink>::SinkItem> + Unpin + 'a + ?Sized,

[+]

type Output = Result<(), <Si as Sink>::SinkError>

🔬 This is a nightly-only experimental API. (futures_api)

futures in libcore are unstable

The result of the Future.

fn poll(     self: PinMut<SendAll<'a, Si, St>>,     cx: &mut Context ) -> Poll<<SendAll<'a, Si, St> as Future>::Output>

[−]

🔬 This is a nightly-only experimental API. (futures_api)

futures in libcore are unstable

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