hu.akarnokd.rxjava2.parallel

Class ParallelTransformers

java.lang.Object

hu.akarnokd.rxjava2.parallel.ParallelTransformers

public final class ParallelTransformers
extends java.lang.Object

Transformers for RxJava 2 ParallelFlowable sequences.

Since:

0.16.3

Method Summary

Modifier and Type	Method and Description
static <T extends java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.Double>	sumDouble() Sums the numbers as longs on each rail.
static <T extends java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.Integer>	sumInteger() Sums the numbers as integers on each rail.
static <T extends java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.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

sumInteger

public static <T extends java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.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 java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.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 java.lang.Number> io.reactivex.parallel.ParallelTransformer<T,java.lang.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