Trait FilterOrderedExt 

pub trait FilterOrderedExt<T>: Stream<Item = StreamItem<T>> + Sized
where
    T: Fluxion,
    T::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static,
    T::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,
{
    // Required method
    fn filter_ordered<F>(
        self,
        predicate: F,
    ) -> impl Stream<Item = StreamItem<T>> + Send + Sync
       where Self: Unpin + Send + Sync + 'static,
             F: FnMut(&T::Inner) -> bool + Send + Sync + 'static;
}

Required Methods

fn filter_ordered<F>( self, predicate: F, ) -> impl Stream<Item = StreamItem<T>> + Send + Sync

where Self: Unpin + Send + Sync + 'static, F: FnMut(&T::Inner) -> bool + Send + Sync + 'static,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<S, T> FilterOrderedExt<T> for S

where S: Stream<Item = StreamItem<T>>, T: Fluxion, T::Inner: Clone + Debug + Ord + Unpin + Send + Sync + 'static, T::Timestamp: Debug + Ord + Copy + Send + Sync + 'static,