Top Description Interfaces Classes Enums
[default module]

Package io.reactivex.rxjava3.parallel

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

Interface Summary

Modifier and TypeInterface and Description
public interface
ParallelFlowableConverter<
the upstream type
T,
the output type
R>

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

public interface
ParallelTransformer<
the upstream value type
Upstream,
the downstream value type
Downstream>

Interface to compose ParallelFlowable.

Class Summary

Modifier and TypeClass and Description
public abstract class
ParallelFlowable<
the value type
T>

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

Enum Summary

Modifier and TypeEnum and Description
public enum
ParallelFailureHandling

Enumerations for handling failure within a parallel operator.