pub trait Positioner<Item> {
type Position: Clone + Ord;
type Checkpoint: Clone;
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
.
Associated Types
type Checkpoint: Clone
Required methods
Updates the position given that token
has been taken from the stream