Struct Sink 

pub struct Sink<A, In, E = (), R = ()>
where
    A: 'static,
    In: Send + 'static,
    E: Send + 'static,
    R: 'static,
{ /* private fields */ }

Consumer that reduces a Stream<In, E, R> to a value of type A.

Implementations

impl<A, In, E, R> Sink<A, In, E, R>

where A: 'static, In: Send + 'static, E: Send + 'static, R: 'static,

pub fn run(self, stream: Stream<In, E, R>) -> Effect<A, E, R>

Run this sink over stream.

impl<A, In, E, R> Sink<A, In, E, R>

where A: Send + Sync + Clone + 'static, In: Send + Sync + Clone + 'static, E: Send + 'static, R: 'static,

pub fn fold_left( init: A, f: impl Fn(A, In) -> A + Send + Sync + 'static, ) -> Self

Left fold over elements (after the stream ends, the accumulator is the result).

pub fn from_fold( init: A, f: impl Fn(A, In) -> A + Send + Sync + 'static, ) -> Self

Alias for Self::fold_left.

pub fn zip<B>(self, other: Sink<B, In, E, R>) -> Sink<(A, B), In, E, R>

where B: Send + Sync + Clone + 'static, In: Clone + Send + 'static,

Combine two Self::fold_left / Self::from_fold sinks into one pass over the stream.

Panics

Panics if either sink was not built with Self::fold_left / Self::from_fold.

impl<In, E, R> Sink<Vec<In>, In, E, R>

where In: Send + Sync + Clone + 'static, E: Send + 'static, R: 'static,

pub fn collect() -> Self

Collect all elements into a vector (in stream order).

pub fn collect_all_while(pred: Predicate<In>) -> Self

Take elements while pred holds; stops before the first failing element (that element is not included in the result).

pub fn collect_all_until(pred: Predicate<In>) -> Self

Take elements until pred becomes true; the first matching element is not included.

impl<In, E, R> Sink<(), In, E, R>

where In: Send + Sync + Clone + 'static, E: Send + 'static, R: 'static,

pub fn drain() -> Self

Discard every element; result is ().

pub fn to_queue(queue: Queue<In>) -> Self

Enqueue each stream element into queue (using () as the queue offer environment).

impl<K, V, E, R> Sink<EffectHashMap<K, V>, (K, V), E, R>

where K: Hash + Eq + Clone + Send + Sync + 'static, V: Clone + Send + Sync + 'static, E: Send + 'static, R: 'static,

pub fn collect_to_map() -> Self

Collect stream elements (K, V) into an EffectHashMap.

Trait Implementations

impl<A, In, E, R> Clone for Sink<A, In, E, R>

where A: 'static, In: Send + 'static, E: Send + 'static, R: 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.