Package io.reactivex.rxjava3.parallel
package io.reactivex.rxjava3.parallel
Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.-
ClassDescriptionEnumerations for handling failure within a parallel operator.Abstract base class for parallel publishing of events signaled to an array of
Subscriber
s.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.