Trait StreamOps

pub trait StreamOps: Stream + Sized {
    // Required methods
    fn debounce_time(self, timeout: Duration) -> DebounceTime<Self>;
    fn distinct(self) -> Distinct<Self>
       where Self::Item: ItemKey;
    fn distinct_until_changed(self) -> DistinctUntilChanged<Self>;
}

Required Methods

fn debounce_time(self, timeout: Duration) -> DebounceTime<Self>

fn distinct(self) -> Distinct<Self>

where Self::Item: ItemKey,

fn distinct_until_changed(self) -> DistinctUntilChanged<Self>

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> StreamOps for S

where S: Stream + Sized,