Function akka_projection_rs_commitlog::offset_store::task

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

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