Trait tokio_stream_ext::StreamOpsExt

pub trait StreamOpsExt: Stream {
    fn distinct_until_changed<Item>(self) -> DistinctUntilChanged<Self, Item>
    where
        Self: Stream<Item = Item> + Sized,
        Item: PartialEq,
    { ... }
    fn debounce(self, debounce_time: Duration) -> Debounce<Self>
    where
        Self: Sized + Unpin,
    { ... }
}

Provided methods

fn distinct_until_changed<Item>(self) -> DistinctUntilChanged<Self, Item> where
    Self: Stream<Item = Item> + Sized,
    Item: PartialEq, 

fn debounce(self, debounce_time: Duration) -> Debounce<Self> where
    Self: Sized + Unpin, 

Implementors

impl<T: ?Sized> StreamOpsExt for T where
    T: Stream,