Struct DelayedSyncBlob 

pub struct DelayedSyncBlob<B> { /* private fields */ }

Blob wrapper that parks each started sync and supports one-shot blocking sync tracking.

A started sync keeps the wrapped blob, and with it the logical open, alive until its handle completes or drops.

Implementations

impl<B> DelayedSyncBlob<B>

pub fn new(inner: B) -> (Self, PendingSyncs)

Wrap inner, returning the blob and the list its deferred syncs are pushed onto.

Trait Implementations

impl<B: Blob> Blob for DelayedSyncBlob<B>

async fn read_at_buf( &self, offset: u64, len: usize, bufs: impl Into<IoBufsMut> + Send, options: ReadOptions, ) -> Result<IoBufsMut, Error>

Read exactly len bytes at offset into caller-provided buffers.

async fn read_at( &self, offset: u64, len: usize, options: ReadOptions, ) -> Result<IoBufsMut, Error>

Read exactly len bytes at offset.

async fn write_at( &self, offset: u64, bufs: impl Into<IoBufs> + Send, options: WriteOptions, ) -> Result<(), Error>

Write every remaining byte in bufs to the blob at offset.

async fn resize(&self, len: u64) -> Result<(), Error>

Resize the blob to the given length.

async fn sync(&self) -> Result<(), Error>

Make every write and resize that completed before this call durable.

async fn start_sync(&self) -> Handle<()>

Request that every write and resize that completed before this call is durable.

fn read_many( &self, ranges: &[(u64, usize)], options: ReadOptions, ) -> impl Stream<Item = Result<(usize, IoBufsMut), Error>> + Send

Read every (offset, len) range in ranges, yielding (range index, buffer) as each read completes, in any order. Each buffer holds the len bytes at offset.

fn start_read_many( &self, ranges: &[(u64, usize)], options: ReadOptions, ) -> impl Future<Output = Handle<Vec<IoBufsMut>>> + Send

Request the len bytes at offset of every (offset, len) range in ranges.