Struct Incremental

pub struct Incremental { /* private fields */ }

Implements an incremental Reader that joins to temporary Storage as the stream data

This is useful for scenarios where the stream isn’t completely buffered in memory and data come in gradually.

Implementations

impl Incremental

pub fn new(current_offset: VarInt) -> Self

pub fn with_storage<'a, C: Storage>( &'a mut self, storage: &'a mut C, is_fin: bool, ) -> Result<WithStorage<'a, C>, Error>

pub fn current_offset(&self) -> VarInt

pub fn final_offset(&self) -> Option<VarInt>

Trait Implementations

impl Debug for Incremental

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Incremental

fn default() -> Incremental

Returns the “default value” for a type.