Trait DatasetStreamExt 

pub trait DatasetStreamExt:
    Stream<Item = AppResult<DataItem>>
    + Sized
    + Send
    + 'static {
    // Provided method
    fn apply_dataset_transform<T>(
        self,
        transform: T,
        limits: DatasetLimits,
    ) -> impl Stream<Item = AppResult<Option<DataItem>>> + Send + 'static
       where T: Transform<DataItem, DataItem> + Clone + Send + Sync + 'static { ... }
}

Extension methods for streams of dataset items.

Provided Methods

fn apply_dataset_transform<T>( self, transform: T, limits: DatasetLimits, ) -> impl Stream<Item = AppResult<Option<DataItem>>> + Send + 'static

where T: Transform<DataItem, DataItem> + Clone + Send + Sync + 'static,

Apply a fallible dataset transform inside a canonical rskit-stream stream.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<S> DatasetStreamExt for S

where S: Stream<Item = AppResult<DataItem>> + Sized + Send + 'static,