MCPcopy Create free account
hub / github.com/clockworklabs/SpacetimeDB / into_async_writer

Method into_async_writer

crates/commitlog/src/stream/common.rs:21–23  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

19 type AsyncWriter = tokio::io::BufWriter<tokio::fs::File>;
20
21 fn into_async_writer(self) -> Self::AsyncWriter {
22 tokio::io::BufWriter::new(tokio::fs::File::from_std(self))
23 }
24}
25
26pub trait AsyncRepo: Repo<SegmentWriter: IntoAsyncWriter<AsyncWriter = Self::AsyncSegmentWriter>> {

Callers 2

create_and_metadataMethod · 0.45
append_allMethod · 0.45

Calls 1

newFunction · 0.50

Tested by

no test coverage detected