Struct asyncplify::ParallelInspect [−] [src]

#[must_use = "stream adaptors are lazy and do nothing unless consumed"]
pub struct ParallelInspect<S, F> {
    // some fields omitted
}

Methods

impl<S, F> ParallelInspect<S, F>

fn new(stream: S, func: F) -> Self

Trait Implementations

impl<S, F> ParallelStream for ParallelInspect<S, F> where S: ParallelStream, F: Send + Sync + Fn(&mut S::Item)

type Item = S::Item

fn consume<C>(self, consumer: C) where C: ParallelConsumer<Self::Item>

fn filter<F>(self, predicate: F) -> ParallelFilter<Self, F> where Self: Sized, F: Send + Fn(&mut Self::Item) -> bool

fn inspect<F>(self, func: F) -> ParallelInspect<Self, F> where F: Send + Sync + Fn(&mut Self::Item), Self: Sized

fn max(self) -> ParallelMax<Self> where Self: Sized

fn max_by_key<F, K>(self, f: F) -> ParallelMaxByKey<Self, F> where Self: Sized, F: Send + Sync + Fn(&Self::Item) -> K, K: PartialOrd + Send

fn min_by_key<F, K>(self, f: F) -> ParallelMinByKey<Self, F> where Self: Sized, F: Send + Sync + Fn(&Self::Item) -> K, K: PartialOrd + Send

fn observe_on<SC>(self, scheduler: SC) -> ParallelObserveOn<Self, SC> where SC: ParallelScheduler, Self: Sized

fn subscribe(self) where Self: Sized

fn subscribe_action<F>(self, action: F) where Self: Sized, F: Fn(Self::Item) + Send + Sync

fn subscribe_func<F>(self, predicate: F) where Self: Sized, F: Send + Sync + Fn(Self::Item) -> bool