Trait Source 

pub trait Source<T> {
    // Required method
    fn next(&mut self) -> Result<Option<T>, FabricError>;
}

Produces items for a pipeline.

Returns Ok(Some(item)) for each available item, Ok(None) when the source is exhausted. Once None is returned, subsequent calls should continue to return None.

Required Methods

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

Implementors

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

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