Function repo

crates/commitlog/tests/streaming/mod.rs:212–214

(at: &Path)

}

fn repo(at: &Path) -> repo::Fs {
    repo::Fs::new(CommitLogDir::from_path_unchecked(at), None).unwrap()
}

fn create_reader<R: RangeBounds<u64>>(path: &Path, range: R) -> impl AsyncBufRead + use<R> {
    BufReader::new(StreamReader::new(stream::commits(