io.reactivex.rxjava4.parallel (RxJava Javadoc 4.0.0-alpha-4)

package io.reactivex.rxjava4.parallel

Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.

Class

Description

ParallelFailureHandling

Enumerations for handling failure within a parallel operator.

ParallelFlowable<T>

Abstract base class for parallel publishing of events signaled to an array of Flow.Subscribers.

ParallelFlowableConverter<T,R>

Convenience interface and callback used by the ParallelFlowable.to(ParallelFlowableConverter) operator to turn a ParallelFlowable into another value fluently.

ParallelTransformer<Upstream, Downstream>

Interface to compose ParallelFlowable.