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