Struct StoreStream 

pub struct StoreStream { /* private fields */ }

The open counterpart of store: offers records one at a time; see store_stream.

Implementations

impl StoreStream

pub async fn offer(&mut self, record: Record) -> Result<StoreRecordDisposition>

Store record into the provider and drive to the next fixed point: Saved when the provider sent it, Skipped when it did not or the provider already held it. An error, or cancelling this future, ends the stream; later calls return the error, and records saved before it stay saved.

pub async fn close(self) -> Result<()>

Cancel the interlace and close the provider, returning the failure that ended the stream with any cleanup failure.