Skip to main content

AsyncItertools

async_itertools

Trait AsyncItertools 

Source 
pub trait AsyncItertools: Stream {
    // Provided methods
    fn zip_longest<U>(self, other: U) -> ZipLongest<Self, U>
       where Self: Sized,
             U: Stream { ... }
    fn coalesce<F>(self, f: F) -> Coalesce<Self, F>
       where Self: Sized,
             F: FnMut(Self::Item, Self::Item) -> Result<Self::Item, (Self::Item, Self::Item)> { ... }
    fn dedup_by<F>(self, f: F) -> DedupBy<Self, F>
       where Self: Sized,
             F: FnMut(&Self::Item, &Self::Item) -> bool { ... }
    fn dedup(self) -> Dedup<Self>
       where Self: Sized,
             Self::Item: PartialEq { ... }
}
Expand description

Itertools extension trait but for Streams instead of Iterators.

Provided Methods§

Source

fn zip_longest<U>(self, other: U) -> ZipLongest<Self, U>
where Self: Sized, U: Stream,

Yields pairs, EitherOrBoth::Both, of items from both streams, until at least one runs out, then either EitherOrBoth::Left (if right ends) or EitherOrBoth::Right (if left ends).

Source

fn coalesce<F>(self, f: F) -> Coalesce<Self, F>
where Self: Sized, F: FnMut(Self::Item, Self::Item) -> Result<Self::Item, (Self::Item, Self::Item)>,

Source

fn dedup_by<F>(self, f: F) -> DedupBy<Self, F>
where Self: Sized, F: FnMut(&Self::Item, &Self::Item) -> bool,

Source

fn dedup(self) -> Dedup<Self>
where Self: Sized, Self::Item: PartialEq,

Dyn Compatibility§

This trait is dyn compatible.

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

Implementors§