pub trait ResetStream: StreamOnce {
    type Checkpoint: Clone;

    fn checkpoint(&self) -> Self::Checkpoint;
    fn reset(&mut self, checkpoint: Self::Checkpoint) -> Result<(), Self::Error>;
}
Expand description

A StreamOnce which can create checkpoints which the stream can be reset to

Required Associated Types

Required Methods

Creates a Checkpoint at the current position which can be used to reset the stream later to the current position

Attempts to reset the stream to an earlier position.

Implementations on Foreign Types

Implementors