[−][src]Trait futures::prelude::SinkExt

pub trait SinkExt<Item>: Sink<Item> {
    default fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>
    where
        E: From<Self::SinkError>,
        F: FnMut(U) -> Fut,
        Fut: Future<Output = Result<Item, E>>,
    { ... }

    default fn with_flat_map<U, St, F>(
        self, 
        f: F
    ) -> WithFlatMap<Self, Item, U, St, F>
    where
        F: FnMut(U) -> St,
        St: Stream<Item = Result<Item, Self::SinkError>>,
    { ... }

    default fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>
    where
        F: FnOnce(Self::SinkError) -> E,
    { ... }

    default fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>
    where
        Self::SinkError: Into<E>,
    { ... }

    default fn buffer(self, capacity: usize) -> Buffer<Self, Item> { ... }

    default fn close(&mut self) -> Close<Self, Item>
    where
        Self: Unpin,
    { ... }

    default fn fanout<Si>(self, other: Si) -> Fanout<Self, Si>
    where
        Item: Clone,
        Si: Sink<Item, SinkError = Self::SinkError>,
    { ... }

    default fn flush(&mut self) -> Flush<Self, Item>
    where
        Self: Unpin,
    { ... }

    default fn send(&mut self, item: Item) -> Send<Self, Item>
    where
        Self: Unpin,
    { ... }

    default fn send_all<St>(
        &'a mut self, 
        stream: &'a mut St
    ) -> SendAll<'a, Self, St>
    where
        Self: Unpin,
        St: Stream<Item = Item> + Unpin,
    { ... }

    default fn left_sink<Si2>(self) -> Either<Self, Si2>
    where
        Si2: Sink<Item, SinkError = Self::SinkError>,
    { ... }

    default fn right_sink<Si1>(self) -> Either<Si1, Self>
    where
        Si1: Sink<Item, SinkError = Self::SinkError>,
    { ... }

    default fn compat(self) -> CompatSink<Self, Item>
    where
        Self: Unpin,
    { ... }
}

An extension trait for Sinks that provides a variety of convenient combinator functions.

Provided methods

default fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where
    E: From<Self::SinkError>,
    F: FnMut(U) -> Fut,
    Fut: Future<Output = Result<Item, E>>, 

Composes a function in front of the sink.

This adapter produces a new sink that passes each value through the given function f before sending it to self.

To process each value, f produces a future, which is then polled to completion before passing its result down to the underlying sink. If the future produces an error, that error is returned by the new sink.

Note that this function consumes the given sink, returning a wrapped version, much like Iterator::map.

default fn with_flat_map<U, St, F>(
    self,
    f: F
) -> WithFlatMap<Self, Item, U, St, F> where
    F: FnMut(U) -> St,
    St: Stream<Item = Result<Item, Self::SinkError>>, 

Composes a function in front of the sink.

This adapter produces a new sink that passes each value through the given function f before sending it to self.

To process each value, f produces a stream, of which each value is passed to the underlying sink. A new value will not be accepted until the stream has been drained

Note that this function consumes the given sink, returning a wrapped version, much like Iterator::flat_map.

Examples

use futures::channel::mpsc;
use futures::executor::block_on;
use futures::sink::SinkExt;
use futures::stream::StreamExt;
use std::collections::VecDeque;

let (tx, rx) = mpsc::channel(5);

let mut tx = tx.with_flat_map(|x| {
    VecDeque::from(vec![Ok(42); x])
});

block_on(tx.send(5)).unwrap();
drop(tx);
let received: Vec<i32> = block_on(rx.collect());
assert_eq!(received, vec![42, 42, 42, 42, 42]);

default fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
    F: FnOnce(Self::SinkError) -> E, 

Transforms the error returned by the sink.

default fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
    Self::SinkError: Into<E>, 

Map this sink's error to a different error type using the Into trait.

If wanting to map errors of a Sink + Stream, use .sink_err_into().err_into().

default fn buffer(self, capacity: usize) -> Buffer<Self, Item>

Adds a fixed-size buffer to the current sink.

The resulting sink will buffer up to capacity items when the underlying sink is unwilling to accept additional items. Calling flush on the buffered sink will attempt to both empty the buffer and complete processing on the underlying sink.

Note that this function consumes the given sink, returning a wrapped version, much like Iterator::map.

This method is only available when the std feature of this library is activated, and it is activated by default.

ⓘImportant traits for Close<'_, Si, Item>
default fn close(&mut self) -> Close<Self, Item> where
    Self: Unpin, 

Close the sink.

default fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where
    Item: Clone,
    Si: Sink<Item, SinkError = Self::SinkError>, 

Fanout items to multiple sinks.

This adapter clones each incoming item and forwards it to both this as well as the other sink at the same time.

ⓘImportant traits for Flush<'_, Si, Item>
default fn flush(&mut self) -> Flush<Self, Item> where
    Self: Unpin, 

Flush the sync, processing all pending items.

This adapter is intended to be used when you want to stop sending to the sink until all current requests are processed.

ⓘImportant traits for Send<'_, Si, Item>
default fn send(&mut self, item: Item) -> Send<Self, Item> where
    Self: Unpin, 

A future that completes after the given item has been fully processed into the sink, including flushing.

Note that, because of the flushing requirement, it is usually better to batch together items to send via send_all, rather than flushing between each item.

ⓘImportant traits for SendAll<'_, Si, St>
default fn send_all<St>(
    &'a mut self,
    stream: &'a mut St
) -> SendAll<'a, Self, St> where
    Self: Unpin,
    St: Stream<Item = Item> + Unpin, 

A future that completes after the given stream has been fully processed into the sink, including flushing.

This future will drive the stream to keep producing items until it is exhausted, sending each item to the sink. It will complete once both the stream is exhausted, the sink has received all items, and the sink has been flushed. Note that the sink is not closed.

Doing sink.send_all(stream) is roughly equivalent to stream.forward(sink). The returned future will exhaust all items from stream and send them to self.

default fn left_sink<Si2>(self) -> Either<Self, Si2> where
    Si2: Sink<Item, SinkError = Self::SinkError>, 

Wrap this sink in an Either sink, making it the left-hand variant of that Either.

This can be used in combination with the right_sink method to write if statements that evaluate to different streams in different branches.

default fn right_sink<Si1>(self) -> Either<Si1, Self> where
    Si1: Sink<Item, SinkError = Self::SinkError>, 

Wrap this stream in an Either stream, making it the right-hand variant of that Either.

This can be used in combination with the left_sink method to write if statements that evaluate to different streams in different branches.

default fn compat(self) -> CompatSink<Self, Item> where
    Self: Unpin, 

Wraps a Sink into a sink compatible with libraries using futures 0.1 Sink. Requires the compat feature to be enabled.

Loading content...

Implementors

impl<T, Item> SinkExt<Item> for T where
    T: Sink<Item> + ?Sized, [src]

default fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where
    E: From<Self::SinkError>,
    F: FnMut(U) -> Fut,
    Fut: Future<Output = Result<Item, E>>, [src]

default fn with_flat_map<U, St, F>(
    self,
    f: F
) -> WithFlatMap<Self, Item, U, St, F> where
    F: FnMut(U) -> St,
    St: Stream<Item = Result<Item, Self::SinkError>>, [src]

default fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
    F: FnOnce(Self::SinkError) -> E, [src]

default fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
    Self::SinkError: Into<E>, [src]

default fn buffer(self, capacity: usize) -> Buffer<Self, Item>[src]

ⓘImportant traits for Close<'_, Si, Item>
default fn close(&mut self) -> Close<Self, Item> where
    Self: Unpin, [src]

default fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where
    Item: Clone,
    Si: Sink<Item, SinkError = Self::SinkError>, [src]

ⓘImportant traits for Flush<'_, Si, Item>
default fn flush(&mut self) -> Flush<Self, Item> where
    Self: Unpin, [src]

ⓘImportant traits for Send<'_, Si, Item>
default fn send(&mut self, item: Item) -> Send<Self, Item> where
    Self: Unpin, [src]

ⓘImportant traits for SendAll<'_, Si, St>
default fn send_all<St>(
    &'a mut self,
    stream: &'a mut St
) -> SendAll<'a, Self, St> where
    Self: Unpin,
    St: Stream<Item = Item> + Unpin, [src]

default fn left_sink<Si2>(self) -> Either<Self, Si2> where
    Si2: Sink<Item, SinkError = Self::SinkError>, [src]

default fn right_sink<Si1>(self) -> Either<Si1, Self> where
    Si1: Sink<Item, SinkError = Self::SinkError>, [src]

default fn compat(self) -> CompatSink<Self, Item> where
    Self: Unpin, [src]

Loading content...