pub trait Positioner<Item> {
type Position: Clone + Ord;
type Checkpoint: Clone;
// Required methods
fn position(&self) -> Self::Position;
fn update(&mut self, token: &Item);
fn checkpoint(&self) -> Self::Checkpoint;
fn reset(&mut self, checkpoint: Self::Checkpoint);
}
Expand description
Trait for tracking the current position of a Stream
.
Required Associated Types§
type Checkpoint: Clone
Required Methods§
sourcefn update(&mut self, token: &Item)
fn update(&mut self, token: &Item)
Updates the position given that token
has been taken from the stream