Enum dvcompute::simulation::stream::Stream

pub enum Stream<T> {
    Cons(ProcessBox<(T, Stream<T>)>),
}

An infinite stream of data.

Variants

Cons(ProcessBox<(T, Stream<T>)>)

Tuple Fields

0: ProcessBox<(T, Stream<T>)>

The cons-cell.

Implementations

impl<T> Stream<T>

pub fn run(self) -> ProcessBox<(T, Self)>

Run the stream computation.

pub fn map<F, B>(self, f: F) -> Stream<B> where
    F: Fn(T) -> B + 'static,
    B: 'static,
    T: 'static, 

Map the stream according the specified function.

pub fn mapc<F, M, B>(self, f: F) -> Stream<B> where
    F: Fn(T) -> M + 'static,
    M: Event<Item = B> + 'static,
    B: 'static,
    T: 'static, 

Compose the stream.

pub fn accum<F, M, B, Acc>(self, f: F, acc: Acc) -> Stream<B> where
    F: Fn(Acc, T) -> M + 'static,
    M: Event<Item = (Acc, B)> + 'static,
    B: 'static,
    T: 'static,
    Acc: 'static, 

Accumulator that outputs a value determined by the specified function.

pub fn filter<F>(self, pred: F) -> Self where
    F: Fn(&T) -> bool + 'static,
    T: 'static, 

Filter only those data values that satisfy to the specified predicate.

pub fn filterc<F, M>(self, pred: F) -> Self where
    F: Fn(&T) -> M + 'static,
    M: Event<Item = bool> + 'static,
    T: 'static, 

Filter only those data values that satisfy to the specified predicate.

pub fn take(self, n: isize) -> Self where
    T: 'static, 

Return the prefix of the stream of the specified length.

pub fn take_while<F>(self, pred: F) -> Self where
    F: Fn(&T) -> bool + 'static,
    T: 'static, 

Return the longest prefix of the stream of elements that satisfy the predicate.

pub fn take_while_c<F, M>(self, pred: F) -> Self where
    F: Fn(&T) -> M + 'static,
    M: Event<Item = bool> + 'static,
    T: 'static, 

Return the longest prefix of the stream of elements that satisfy the computations.

pub fn drop(self, n: isize) -> Self where
    T: 'static, 

Return the suffix of the stream after the specified first elements.

pub fn drop_while<F>(self, pred: F) -> Self where
    F: Fn(&T) -> bool + 'static,
    T: 'static, 

Return the suffix of the stream of elements remaining after take_while.

pub fn drop_while_c<F, M>(self, pred: F) -> Self where
    F: Fn(&T) -> M + 'static,
    M: Event<Item = bool> + 'static,
    T: 'static, 

Return the suffix of the stream of elements remaining after take_while_c.