Function akka_projection_rs_commitlog::offset_store::run

pub async fn run(
    commit_log: FileLog,
    keys_expected: usize,
    offset_store_id: OffsetStoreId,
    offset_store_receiver: Receiver<Command>
) -> Result<()>

Runs an offset store.