Struct EffectStream 

pub struct EffectStream<R, E, A> { /* private fields */ }

Implementations

impl<R, E, A> EffectStream<R, E, A>

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

pub fn from_iter<I>(iter: I) -> Self

where I: IntoIterator<Item = A> + Send + Sync + 'static, I::IntoIter: Send,

Creates a stream from an iterator.

pub fn map<B, F>(self, f: F) -> EffectStream<R, E, B>

where F: Fn(A) -> B + Send + Sync + 'static + Clone, B: Send + Sync + Clone + 'static,

Maps over elements of the stream.

pub fn run_collect(self) -> Effect<R, E, Vec<A>>

Runs the stream and collects all values into a Vec.

pub fn merge(self, other: EffectStream<R, E, A>) -> EffectStream<R, E, A>

pub fn map_par<B, F>(self, concurrency: usize, f: F) -> EffectStream<R, E, B>

where F: Fn(A) -> Effect<R, E, B> + Send + Sync + 'static + Clone, B: Send + Sync + Clone + 'static, R: 'static + Send + Sync + Clone, E: 'static + Send + Sync + Clone,

pub fn buffer(self, capacity: usize) -> EffectStream<R, E, A>

pub fn take(self, n: usize) -> EffectStream<R, E, A>

pub fn filter<F>(self, f: F) -> EffectStream<R, E, A>

where F: Fn(&A) -> bool + Send + Sync + 'static + Clone,

Trait Implementations

impl<R, E, A> Clone for EffectStream<R, E, A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.