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 theParallelFlowable.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 ofSubscriber
s. -
Enum Summary Enum Description ParallelFailureHandling Enumerations for handling failure within a parallel operator.