Class ParallelReduce<T,R>

java.lang.Object

io.reactivex.rxjava3.parallel.ParallelFlowable<R>

io.reactivex.rxjava3.internal.operators.parallel.ParallelReduce<T,R>

Type Parameters:

T - the input value type

R - the result value type

public final class ParallelReduce<T,R>
extends ParallelFlowable<R>

Reduce the sequence of values in each 'rail' to a single value.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ParallelReduce.ParallelReduceSubscriber<T,R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Supplier<R>	initialSupplier
(package private) final BiFunction<R, ? super T, R>	reducer
(package private) final ParallelFlowable<? extends T>	source

Constructor Summary

Constructors

Constructor	Description
ParallelReduce(ParallelFlowable<? extends T> source, Supplier<R> initialSupplier, BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and Type	Method	Description
int	parallelism()	Returns the number of expected parallel Subscribers.
(package private) void	reportError(org.reactivestreams.Subscriber<?>[] subscribers, Throwable ex)
void	subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)	Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.

Methods inherited from class ParallelFlowable

collect, collect, compose, concatMap, concatMap, concatMapDelayError, concatMapDelayError, doAfterNext, doAfterTerminated, doOnCancel, doOnComplete, doOnError, doOnNext, doOnNext, doOnNext, doOnRequest, doOnSubscribe, filter, filter, filter, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, flatMapStream, flatMapStream, from, from, from, fromArray, map, map, map, mapOptional, mapOptional, mapOptional, reduce, reduce, runOn, runOn, sequential, sequential, sequentialDelayError, sequentialDelayError, sorted, sorted, to, toSortedList, toSortedList, validate

Methods inherited from class Object

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

Field Details

source

final ParallelFlowable<? extends T> source

initialSupplier

final Supplier<R> initialSupplier

reducer

final BiFunction<R, ? super T, R> reducer

Constructor Details

ParallelReduce

public ParallelReduce(ParallelFlowable<? extends T> source,
 Supplier<R> initialSupplier,
 BiFunction<R, ? super T, R> reducer)

Method Details

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)

Description copied from class: ParallelFlowable

Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.

Backpressure:

The backpressure behavior/expectation is determined by the supplied Subscriber.

Scheduler:

subscribe does not operate by default on a particular Scheduler.

Specified by:

subscribe in class ParallelFlowable<R>

Parameters:

subscribers - the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable

See Also:

• ParallelFlowable.parallelism()

reportError

void reportError(org.reactivestreams.Subscriber<?>[] subscribers,
 Throwable ex)

parallelism

public int parallelism()

Description copied from class: ParallelFlowable

Returns the number of expected parallel Subscribers.

Specified by:

parallelism in class ParallelFlowable<R>

Returns:

the number of expected parallel Subscribers