Struct FnStream

pub struct FnStream<'a, T: Clone> { /* private fields */ }

Basic stream type. To use it you should provide getter function:

use streams_rs::{*,fn_stream::*};
let get = (|| StreamResult::Ok(1));
let mut stream = FnStream::new(get);
stream.token(0); // 1
stream.token(1); // 1

Implementations

impl<'a, T: Clone> FnStream<'a, T>

pub fn new(get: impl FnMut() -> StreamResult<T> + 'a) -> Self

Examples found in repository

examples/counter.rs (line 11)

fn main() {
    let mut count = 0;
    let get = || {
        count += 1;
        StreamResult::Ok(count - 1)
    };
    let mut stream = FnStream::new(get);

    let _ = smatch!(match (stream) {
        [0=>] => {  // if not 0 then we do not match
            println!("Zero!");
        }
    });
    let _ = smatch!(match (stream) {
        [1=>] => { // if not 1 then we do not match
            println!("One!");
        }
    });
    for _ in 0..10 {
        let _ = smatch!(match (stream) {
            [a=>b=>] => { // get two values a and b from stream
                println!("a: {} b: {}",a,b);
            }
        });
    }
}

Trait Implementations

impl<'a, T: Clone> Stream<'a> for FnStream<'a, T>

type Item = T

fn token(&mut self, x: usize) -> StreamResult<T>

Returns token at x. It’s possible to cache values. FnStream for example caches all tokens returned from getter.

fn junk(&mut self, x: usize)

Basucally same as truncating vector.

fn pos(&self) -> usize

Return stream position, does not used by macro or streams-rs, but might be usefull for someone.