Struct StreamThunk 

pub struct StreamThunk<S: Clone, T> { /* private fields */ }

An infinite stream backed by a generating function.

The generator is called with a mutable state value to produce the next element.

Implementations

impl<S: Clone + Debug, T: Clone + Debug> StreamThunk<S, T>

pub fn new<F>(init: S, f: F) -> Self

where F: Fn(&S) -> (T, S) + 'static,

Create a new stream with initial state s and generator f.

f(state) returns (next_value, next_state).

pub fn next(&mut self) -> T

Produce the next value and advance the stream.

pub fn take_n(&mut self, n: usize) -> Vec<T>

Take n elements and return them as a vector.

pub fn current_state(&self) -> &S

Peek at the current state without advancing.