Trait ReplaySink 

pub trait ReplaySink: Send + 'static {
    type Msg: Send + 'static;

    // Required method
    fn make_on_entry(entry: JournalEntry, reply: Sender<()>) -> Self::Msg;
}

Trait the user implements to consume replayed entries. The actor receives one OnEntry { entry } message per replay event; the reply lets the harness pace the replay (next entry waits for the sink’s reply).

Required Associated Types

type Msg: Send + 'static

Required Methods

fn make_on_entry(entry: JournalEntry, reply: Sender<()>) -> Self::Msg

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors