hu.akarnokd.rxjava3.parallel

Class ParallelTransformers

java.lang.Object

hu.akarnokd.rxjava3.parallel.ParallelTransformers

public final class ParallelTransformers
extends Object

Transformers for RxJava 2 ParallelFlowable sequences.

Since:

0.16.3

Method Summary

Modifier and Type	Method and Description
static <T extends Comparable<? super T>> Flowable<T>	orderedMerge(ParallelFlowable<T> source) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order).
static <T extends Comparable<? super T>> Flowable<T>	orderedMerge(ParallelFlowable<T> source, boolean delayErrors) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order) and allows delaying any error they may signal.
static <T extends Comparable<? super T>> Flowable<T>	orderedMerge(ParallelFlowable<T> source, boolean delayErrors, int prefetch) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.
static <T> Flowable<T>	orderedMerge(ParallelFlowable<T> source, Comparator<? super T> comparator) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator).
static <T> Flowable<T>	orderedMerge(ParallelFlowable<T> source, Comparator<? super T> comparator, boolean delayErrors) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator) and allows delaying any error they may signal.
static <T> Flowable<T>	orderedMerge(ParallelFlowable<T> source, Comparator<? super T> comparator, boolean delayErrors, int prefetch) Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.
static <T extends Number> ParallelTransformer<T,Double>	sumDouble() Sums the numbers as longs on each rail.
static <T extends Number> ParallelTransformer<T,Integer>	sumInteger() Sums the numbers as integers on each rail.
static <T extends Number> ParallelTransformer<T,Long>	sumLong() Sums the numbers as longs on each rail.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

orderedMerge

public static <T extends Comparable<? super T>> Flowable<T> orderedMerge(ParallelFlowable<T> source)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order).

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

Returns:

the new Flowable instance

Since:

0.17.9

orderedMerge

public static <T extends Comparable<? super T>> Flowable<T> orderedMerge(ParallelFlowable<T> source,
                                                                         boolean delayErrors)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order) and allows delaying any error they may signal.

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

delayErrors - if true, source errors are delayed until all sources terminate in some way

Returns:

the new Flowable instance

Since:

0.17.9

orderedMerge

public static <T extends Comparable<? super T>> Flowable<T> orderedMerge(ParallelFlowable<T> source,
                                                                         boolean delayErrors,
                                                                         int prefetch)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by their natural order), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

delayErrors - if true, source errors are delayed until all sources terminate in some way

prefetch - the number of items to prefetch from the sources

Returns:

the new Flowable instance

Since:

0.17.9

orderedMerge

public static <T> Flowable<T> orderedMerge(ParallelFlowable<T> source,
                                           Comparator<? super T> comparator)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator).

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

comparator - the comparator to use for comparing items; it is called with the last known smallest in its first argument

Returns:

the new Flowable instance

Since:

0.17.9

orderedMerge

public static <T> Flowable<T> orderedMerge(ParallelFlowable<T> source,
                                           Comparator<? super T> comparator,
                                           boolean delayErrors)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator) and allows delaying any error they may signal.

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

comparator - the comparator to use for comparing items; it is called with the last known smallest in its first argument

delayErrors - if true, source errors are delayed until all sources terminate in some way

Returns:

the new Flowable instance

Since:

0.17.9

orderedMerge

public static <T> Flowable<T> orderedMerge(ParallelFlowable<T> source,
                                           Comparator<? super T> comparator,
                                           boolean delayErrors,
                                           int prefetch)

Merges the source ParallelFlowable rails in an ordered fashion picking the smallest of the available value from them (determined by the Comparator), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.

Type Parameters:

T - the value type of all sources

Parameters:

source - the source ParallelFlowable

comparator - the comparator to use for comparing items; it is called with the last known smallest in its first argument

delayErrors - if true, source errors are delayed until all sources terminate in some way

prefetch - the number of items to prefetch from the sources

Returns:

the new Flowable instance

Since:

0.17.9

sumInteger

public static <T extends Number> ParallelTransformer<T,Integer> sumInteger()

Sums the numbers as integers on each rail.

Type Parameters:

T - the numerical type of the input values

Returns:

the new ParallelTransformer type

Since:

0.16.3

sumLong

public static <T extends Number> ParallelTransformer<T,Long> sumLong()

Sums the numbers as longs on each rail.

Type Parameters:

T - the numerical type of the input values

Returns:

the new ParallelTransformer type

Since:

0.16.3

sumDouble

public static <T extends Number> ParallelTransformer<T,Double> sumDouble()

Sums the numbers as longs on each rail.

Type Parameters:

T - the numerical type of the input values

Returns:

the new ParallelTransformer type

Since:

0.16.3