Struct GeneratorSource

pub struct GeneratorSource<T, F>
where
    F: FnMut() -> Option<T> + Send,
{ /* private fields */ }

A source that generates test data

Implementations

impl<T, F> GeneratorSource<T, F>

where F: FnMut() -> Option<T> + Send,

pub fn new(generator: F) -> Self

Create a new generator source

pub fn counter( start: i64, end: i64, ) -> GeneratorSource<i64, impl FnMut() -> Option<i64>>

Create a counting source that generates numbers from start to end

Trait Implementations

impl<T, F> Source<T> for GeneratorSource<T, F>

where T: Send, F: FnMut() -> Option<T> + Send + Sync,

fn init<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the source

fn next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<Option<Record<T>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read the next record from the source

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the source and release resources