Function akka_projection_rs::volatile_offset_store::task

pub fn task(
    keys_expected: usize
) -> (impl Future<Output = Result<()>>, Sender<Command>)

Provides an asynchronous task and a command channel that can run and drive an in-memory offset store.