pub trait StreamingDataReader: Send + Sync {
// Required methods
fn read_chunk(&mut self, chunk_size: usize) -> Result<Option<DataChunk>>;
fn has_more(&self) -> bool;
fn reset(&mut self) -> Result<()>;
}Expand description
Streaming reader trait