Trait JournalConsumer 

pub trait JournalConsumer<A: Application>: Send + 'static {
    // Required methods
    fn resume(&self) -> Position;
    fn drain(
        &mut self,
        entries: Vec<Arc<Entry<Recorded<A>>>>,
        applied: Position,
    ) -> impl Future<Output = Position> + Send;

    // Provided methods
    fn flush(&mut self) -> impl Future<Output = ()> + Send { ... }
    fn redelivered(&mut self, stored: &[(Position, Vec<u8>)]) { ... }
}

Required Methods

fn resume(&self) -> Position

fn drain( &mut self, entries: Vec<Arc<Entry<Recorded<A>>>>, applied: Position, ) -> impl Future<Output = Position> + Send

Provided Methods

fn flush(&mut self) -> impl Future<Output = ()> + Send

fn redelivered(&mut self, stored: &[(Position, Vec<u8>)])

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors