Type Alias StreamFx 

pub type StreamFx<'f, I, S> = Fx<'f, S, Stream<'f, I, S>>;

Aliased Type

pub struct StreamFx<'f, I, S>(/* private fields */);

Implementations

impl<'f, I: Clone, S: Clone> StreamFx<'f, I, S>

pub fn concat(self, tail: Self) -> Self

pub fn fold_stream<A, F>(f: F) -> Fx<'f, (Self, (A, S)), A>

where A: Clone + 'f, F: FnOnce(A, I) -> Fx<'f, S, Item<A>> + Clone + 'f,

pub fn fold<A, F>(self, f: F) -> Fx<'f, (A, S), A>

where A: Clone + 'f, F: FnOnce(A, I) -> Fx<'f, S, Item<A>> + Clone + 'f,