Struct Data 

pub struct Data<T> { /* private fields */ }

A cloneable, type-erased handle to a Dataset.

Implementations

impl<T: Send + 'static> Data<T>

pub fn new(dataset: impl Dataset<T>) -> Self

Wraps dataset.

pub async fn write(&self, item: T) -> Result<()>

Stores an item.

Errors

Returns an error if the underlying dataset fails.

pub async fn write_all(&self, items: impl IntoIterator<Item = T>) -> Result<()>

Stores every item of items, stopping at the first error.

Errors

Returns an error if the underlying dataset fails.

pub async fn read(&self) -> Result<Option<T>>

Takes the next item, or None if the dataset is empty.

Errors

Returns an error if the underlying dataset fails.

pub async fn read_batch(&self, max: usize) -> Result<Vec<T>>

Takes up to max items at once, see Dataset::read_batch.

Errors

Returns an error if the underlying dataset fails.

pub async fn read_all(&self) -> Result<Vec<T>>

Takes every item until the dataset is empty, in batches of READ_BATCH items.

Errors

Returns an error if the underlying dataset fails.

pub fn into_stream(self) -> impl Stream<Item = Result<T>> + Send

Returns a stream that takes items one at a time until the dataset is empty, so it never takes an item it does not yield. To drain a large dataset, into_batches takes fewer trips to its storage.

pub fn into_batches( self, max: usize, ) -> impl Stream<Item = Result<Vec<T>>> + Send

Returns a stream that takes batches of up to max items, see Dataset::read_batch, until the dataset is empty.

pub fn size_hint(&self) -> Option<usize>

Returns the number of stored items, if known.

Trait Implementations

impl<T> Clone for Data<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Send + 'static> Dataset<T> for Data<T>

fn write(&self, item: T) -> impl Future<Output = Result<()>> + Send

Stores an item.

fn read(&self) -> impl Future<Output = Result<Option<T>>> + Send

Takes the next item, or None if the dataset is empty.

fn read_batch(&self, max: usize) -> impl Future<Output = Result<Vec<T>>> + Send

Takes up to max items at once, in the order read takes them; fewer, or none, once the dataset runs out.

fn size_hint(&self) -> Option<usize>

Returns the number of stored items, if known.

impl<T> Debug for Data<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.