Struct VecSource 

pub struct VecSource<T> { /* private fields */ }

Source that yields items from a Vec<T> in FIFO order.

Items are stored in reverse internally so that pop() yields them front-to-back in O(1) time. Once all items have been yielded, next() returns Ok(None).

Example

use grafos_stream::source::VecSource;
use grafos_stream::stage::Source;

let mut src = VecSource::new(vec![10, 20, 30]);
assert_eq!(src.next().unwrap(), Some(10));
assert_eq!(src.next().unwrap(), Some(20));
assert_eq!(src.next().unwrap(), Some(30));
assert_eq!(src.next().unwrap(), None);

Implementations

impl<T> VecSource<T>

pub fn new(items: Vec<T>) -> Self

Create a source from a vector.

Values are yielded in the same order as the input vector.

Trait Implementations

impl<T> Source<T> for VecSource<T>

fn next(&mut self) -> Result<Option<T>, FabricError>