Struct asyncplify::SyncToParallelObserveOn

pub struct SyncToParallelObserveOn<S, SC> {
    // some fields omitted
}

Methods

impl<S, SC> SyncToParallelObserveOn<S, SC>

fn new(stream: S, scheduler: SC) -> Self

Trait Implementations

impl<S, SC> ParallelStream for SyncToParallelObserveOn<S, SC> where S: Stream, S::Item: Send + 'static, SC: ParallelScheduler

type Item = S::Item

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

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