public final Class ParallelFromArray<T>

Class Inheritance

extends ParallelFlowable<T>

Type Parameters

Imports

Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.

Field Summary

Modifier and Type	Field and Description
pack-priv final Publisher<T>[]	sources

Access	Constructor and Description
public	ParallelFromArray(Publisher<T>[] sources)

Modifier and Type	Method and Description
public int	parallelism() Implements abstract io.reactivex.parallel.ParallelFlowable.parallelism. Returns the number of expected parallel Subscribers.
public void	subscribe(Subscriber<? super T>[] the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable subscribers) Implements abstract io.reactivex.parallel.ParallelFlowable.subscribe. Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.

sources	back to summary
pack-priv final Publisher<T>[] sources

ParallelFromArray	back to summary
public ParallelFromArray(Publisher<T>[] sources)

parallelism	back to summary
public int parallelism() Implements abstract io.reactivex.parallel.ParallelFlowable.parallelism. Doc from io.reactivex.parallel.ParallelFlowable.parallelism. Returns the number of expected parallel Subscribers. Returns:int the number of expected parallel Subscribers Annotations @Override

parallelism

public int parallelism()

Returns the number of expected parallel Subscribers.

Returns:int

the number of expected parallel Subscribers

Annotations

subscribe	back to summary
public void subscribe(Subscriber<? super T>[] subscribers) Implements abstract io.reactivex.parallel.ParallelFlowable.subscribe. Doc from io.reactivex.parallel.ParallelFlowable.subscribe. Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'. Parameters subscribers:Subscriber<? super T>[] the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable Annotations @Override

public void subscribe(Subscriber<? super T>[] subscribers)

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

Parameters

subscribers:Subscriber<? super T>[]: the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable

Annotations