Struct IterSource 

pub struct IterSource<T, I: Iterator<Item = T>> { /* private fields */ }

Source that yields items from an iterator.

Wraps any Iterator<Item = T> as a Source<T>.

Example

use grafos_stream::source::IterSource;
use grafos_stream::stage::Source;

let mut src = IterSource::new(0..3);
assert_eq!(src.next().unwrap(), Some(0));
assert_eq!(src.next().unwrap(), Some(1));
assert_eq!(src.next().unwrap(), Some(2));
assert_eq!(src.next().unwrap(), None);

Implementations

impl<T, I: Iterator<Item = T>> IterSource<T, I>

pub fn new(iter: I) -> Self

Wrap an iterator as a Source.

Trait Implementations

impl<T, I: Iterator<Item = T>> Source<T> for IterSource<T, I>

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