Package io.reactivex.rxjava3.parallel

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

Interface Summary

Interface	Description
ParallelFlowableConverter<T,R>	Convenience interface and callback used by the ParallelFlowable.to(io.reactivex.rxjava3.parallel.ParallelFlowableConverter<T, R>) operator to turn a ParallelFlowable into another value fluently.
ParallelTransformer<Upstream,Downstream>	Interface to compose ParallelFlowable.

Class Summary

Class	Description
ParallelFlowable<T>	Abstract base class for parallel publishing of events signaled to an array of Subscribers.

Enum Summary

Enum	Description
ParallelFailureHandling	Enumerations for handling failure within a parallel operator.