Trait StateStoreIterExt

pub trait StateStoreIterExt<T: IterItem = StateStoreKeyedRow>: StateStoreIter<T> + Sized {
    type ItemStream<O: Send, F: Send + for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O>>: Stream<Item = StorageResult<O>> + Send;

    // Required method
    fn into_stream<O: Send, F: for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O> + Send>(
        self,
        f: F,
    ) -> Self::ItemStream<O, F>;

    // Provided method
    fn fused(self) -> FusedStateStoreIter<Self, T> { ... }
}

Required Associated Types

type ItemStream<O: Send, F: Send + for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O>>: Stream<Item = StorageResult<O>> + Send

Required Methods

fn into_stream<O: Send, F: for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O> + Send>( self, f: F, ) -> Self::ItemStream<O, F>

Provided Methods

fn fused(self) -> FusedStateStoreIter<Self, T>

Object Safety

This trait is not object safe.

Implementors

impl<T: IterItem, I: StateStoreIter<T>> StateStoreIterExt<T> for I

type ItemStream<O: Send, F: Send + for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O>> = impl Stream<Item = Result<O, StorageError>> + Send