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_all(&self) -> Result<Vec<T>>

Takes every item until the dataset is empty.

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 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 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.