Struct Sink 

pub struct Sink;

Implementations

impl Sink

pub async fn fold<T, Acc, F>(source: Source<T>, init: Acc, f: F) -> Acc

where T: Send + 'static, Acc: Send + 'static, F: FnMut(Acc, T) -> Acc + Send + 'static,

akka.net: Fold — drive the source and accumulate a single value.

pub async fn fold_async<T, Acc, F, Fut>( source: Source<T>, init: Acc, f: F, ) -> Acc

where T: Send + 'static, Acc: Send + 'static, F: FnMut(Acc, T) -> Fut + Send + 'static, Fut: Future<Output = Acc> + Send + 'static,

akka.net: AggregateAsync — async fold.

pub async fn collect<T>(source: Source<T>) -> Vec<T>

where T: Send + 'static,

akka.net: Sink.Seq — collect into a Vec.

pub async fn first<T>(source: Source<T>) -> Option<T>

where T: Send + 'static,

akka.net: Sink.First.

pub async fn last<T>(source: Source<T>) -> Option<T>

where T: Send + 'static,

akka.net: Sink.Last.

pub async fn sum<T>(source: Source<T>) -> T

where T: Send + Default + Add<Output = T> + 'static,

akka.net: Sink.Sum.

pub async fn count<T>(source: Source<T>) -> u64

where T: Send + 'static,

akka.net: Sink.Count.

pub async fn for_each<T, F>(source: Source<T>, f: F)

where T: Send + 'static, F: FnMut(T) + Send + 'static,

pub async fn for_each_async<T, F, Fut>( source: Source<T>, parallelism: usize, f: F, )

where T: Send + 'static, F: FnMut(T) -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

akka.net: Sink.ForEachAsync.

pub async fn ignore<T: Send + 'static>(source: Source<T>)

akka.net: Sink.Ignore.

pub async fn to_sender<T>(source: Source<T>, tx: UnboundedSender<T>)

where T: Send + 'static,

Send each element to an UnboundedSender. akka.net: Sink.ActorRef (atomr equivalent uses an mpsc channel).

pub fn queue<T>(source: Source<T>) -> SinkQueue<T>

where T: Send + 'static,

akka.net: Sink.Queue — run the source and expose a pull-based API. The returned SinkQueue::pull future returns Ok(Some(t)) per element, Ok(None) after the stream completes.

pub async fn pull_with_timeout<T: Send + 'static>( q: &SinkQueue<T>, t: Duration, ) -> Option<T>

Sink.Queue with a bounded element timeout per pull.