Struct StreamingDataset 

pub struct StreamingDataset<F> { /* private fields */ }

Factory-backed dataset enabling restartable streaming.

Implementations

impl<F> StreamingDataset<F>

pub const fn new(factory: F, row_count_hint: Option<u64>) -> Self

Creates a dataset from a factory returning a fresh iterator per visit.

Trait Implementations

impl<F, I> Dataset for StreamingDataset<F>

where F: Fn() -> I + Send + Sync, I: Iterator<Item = Result<DataRow>>,

fn row_count_hint(&self) -> Option<u64>

Optional exact row count.

fn visit_rows_until( &self, visitor: &mut dyn FnMut(u64, &DataRow) -> Result<bool>, ) -> Result<()>

Visits rows in stable order until the visitor returns false.

fn visit_rows( &self, visitor: &mut dyn FnMut(u64, &DataRow) -> Result<()>, ) -> Result<()>

Visits every row without requiring full materialization.