AsyncItertools

ruchei_itertools

Trait AsyncItertools 

Source 
pub trait AsyncItertools: Stream {
    // Provided methods
    fn advance_by(&mut self, n: usize) -> AdvanceBy<'_, Self>
       where Self: Unpin { ... }
    fn all_equal(self) -> AllEqual<Self>
       where Self: Sized,
             Self::Item: PartialEq { ... }
    fn cmp<J>(self, other: J) -> Cmp<Self, J>
       where Self: Sized,
             Self::Item: Ord,
             J: Stream<Item = Self::Item> { ... }
    fn cmp_by<J, F>(self, other: J, cmp: F) -> CmpBy<Self, J, F>
       where Self: Sized,
             J: Stream,
             F: FnMut(&Self::Item, &J::Item) -> Ordering { ... }
    fn dedup_eager(self) -> DedupEager<Self>
       where Self: Sized,
             Self::Item: PartialEq + Clone { ... }
    fn interleave<J>(self, other: J) -> Interleave<Self, J>
       where Self: Sized,
             J: Stream<Item = Self::Item> { ... }
    fn partial_cmp<J>(self, other: J) -> PartialCmp<Self, J>
       where Self: Sized,
             Self::Item: PartialOrd<J::Item>,
             J: Stream { ... }
    fn partial_cmp_by<J, F>(self, other: J, cmp: F) -> PartialCmpBy<Self, J, F>
       where Self: Sized,
             J: Stream,
             F: FnMut(&Self::Item, &J::Item) -> Option<Ordering> { ... }
    fn try_zip_lazy<J>(self, other: J) -> TryZipLazy<Self, J>
       where Self: Sized + TryStream,
             J: TryStream<Error = Self::Error> { ... }
    fn zip_lazy<J>(self, other: J) -> ZipLazy<Self, J>
       where Self: Sized,
             J: Stream { ... }
    fn zip_longest<J>(self, other: J) -> ZipLongest<Self, J>
       where Self: Sized,
             J: Stream { ... }
}
Expand description

Itertools for Streams

most combinators also forward futures-sink and route-sink methods

Provided Methods§

Source

fn advance_by(&mut self, n: usize) -> AdvanceBy<'_, Self>
where Self: Unpin,

Source

fn all_equal(self) -> AllEqual<Self>
where Self: Sized, Self::Item: PartialEq,

Source

fn cmp<J>(self, other: J) -> Cmp<Self, J>
where Self: Sized, Self::Item: Ord, J: Stream<Item = Self::Item>,

Source

fn cmp_by<J, F>(self, other: J, cmp: F) -> CmpBy<Self, J, F>
where Self: Sized, J: Stream, F: FnMut(&Self::Item, &J::Item) -> Ordering,

Source

fn dedup_eager(self) -> DedupEager<Self>
where Self: Sized, Self::Item: PartialEq + Clone,

deduplicates items, and yields them as soon as they become available (that’s why Clone)

Source

fn interleave<J>(self, other: J) -> Interleave<Self, J>
where Self: Sized, J: Stream<Item = Self::Item>,

Source

fn partial_cmp<J>(self, other: J) -> PartialCmp<Self, J>
where Self: Sized, Self::Item: PartialOrd<J::Item>, J: Stream,

Source

fn partial_cmp_by<J, F>(self, other: J, cmp: F) -> PartialCmpBy<Self, J, F>
where Self: Sized, J: Stream, F: FnMut(&Self::Item, &J::Item) -> Option<Ordering>,

Source

fn try_zip_lazy<J>(self, other: J) -> TryZipLazy<Self, J>
where Self: Sized + TryStream, J: TryStream<Error = Self::Error>,

Source

fn zip_lazy<J>(self, other: J) -> ZipLazy<Self, J>
where Self: Sized, J: Stream,

Source

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

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§