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

Method poll_write

crates/commitlog/src/repo/mem/segment.rs:288–290  ·  view source on GitHub ↗
(self: Pin<&mut Self>, _: &mut Context<'_>, buf: &[u8])

Source from the content-addressed store, hash-verified

286
287 impl AsyncWrite for Segment {
288 fn poll_write(self: Pin<&mut Self>, _: &mut Context<'_>, buf: &[u8]) -> Poll<io::Result<usize>> {
289 Poll::Ready(self.get_mut().write(buf))
290 }
291
292 fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> {
293 Poll::Ready(Ok(()))

Callers

nothing calls this directly

Calls 2

writeMethod · 0.45
get_mutMethod · 0.45

Tested by

no test coverage detected