Struct Accum 

pub struct Accum<Acc, Input, C, F> { /* private fields */ }

Implementations

impl<Acc, Input, C, F: FnMut(&mut Acc, Input)> Accum<Acc, Input, C, F>

pub fn new(acc: Acc, f: F) -> Self

Trait Implementations

impl<Acc: Clone, Input, C, F: FnMut(&mut Acc, Input)> StreamFunction for Accum<Acc, Input, C, F>

type Input = Input

type Output = Acc

type Clock = C

type Error = ()

fn step( &mut self, input: Self::Input, _: Self::Clock, ) -> Result<Self::Output, Self::Error>

fn map<U, F>(self, f: F) -> Map<Self, U>

where Self: Sized, F: 'static + Fn(Self::Output) -> U,

fn apply_to<Input, C, I: Iterator<Item = (Input, C)>>( self, iterator: I, ) -> Apply<I, Self>

where Self: Sized,

fn iter(self) -> Iter<Self>

where Self: Sized,

fn and_then<SF: StreamFunction<Input = Self::Output, Clock = Self::Clock, Error = Self::Error>>( self, sf: SF, ) -> Composition<Self, SF>

where Self: Sized,

fn parallel<SF: StreamFunction>(self, sf: SF) -> Parallel<Self, SF>

where Self: Sized,

fn fan_out<SF: StreamFunction<Input = Self::Input, Clock = Self::Clock, Error = Self::Error>>( self, sf: SF, ) -> FanOut<Self::Input, Self::Clock, Self::Error, Self, SF>

where Self: Sized, Self::Input: Clone, Self::Clock: Copy,