| Modifier and Type | Class and Description |
|---|---|
| public class | ParallelCollect<
the input value type T, the collection type C>Reduce the sequence of values in each 'rail' to a single value. |
| public class | ParallelConcatMap<
the input value type T, the output value type R>Concatenates the generated Publishers on each rail. |
| public class | ParallelDoOnNextTry<
the input value type T>Calls a Consumer for each upstream value passing by and handles any failure with a handler function. |
| public class | ParallelFilter<
the input value type T>Filters each 'rail' of the source ParallelFlowable with a predicate function. |
| public class | ParallelFilterTry<
the input value type T>Filters each 'rail' of the source ParallelFlowable with a predicate function. |
| public class | ParallelFlatMap<
the input value type T, the output value type R>Flattens the generated Publishers on each rail. |
| public class | ParallelFromArray<
the value type T>Wraps multiple Publishers into a ParallelFlowable which runs them in parallel. |
| public class | ParallelFromPublisher<
the value type T>Dispatches the values from upstream in a round robin fashion to subscribers which are ready to consume elements. |
| public class | ParallelJoin<
the value type T>Merges the individual 'rails' of the source ParallelFlowable, unordered, into a single regular Publisher sequence (exposed as Flowable). |
| public class | ParallelMap<
the input value type T, the output value type R>Maps each 'rail' of the source ParallelFlowable with a mapper function. |
| public class | ParallelMapTry<
the input value type T, the output value type R>Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function. |
| public class | ParallelPeek<
the value type T>Execute a Consumer in each 'rail' for the current element passing through. |
| public class | ParallelReduce<
the input value type T, the result value type R>Reduce the sequence of values in each 'rail' to a single value. |
| public class | ParallelReduceFull<
the value type T>Reduces all 'rails' into a single value which then gets reduced into a single Publisher sequence. |
| public class | |
| public class | ParallelSortedJoin<
the value type T>Given sorted rail sequences (according to the provided comparator) as List emit the smallest item from these parallel Lists to the Subscriber. |