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.

Required Associated Types

The type which keeps track of the position

Required Methods

Returns the current position

Updates the position given that token has been taken from the stream

Implementations on Foreign Types

Implementors