Trait StreamOpsExt 

pub trait StreamOpsExt: Stream {
    // 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 { ... }
}

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> StreamOpsExt for T

where T: Stream + ?Sized,