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.rxjava3.parallel.ParallelFlowable.parallelism. Returns the number of expected parallel `Subscriber`s.
public void	subscribe(Subscriber<? super T>[] subscribers)

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

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

parallelism back to summary

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

public int parallelism()

Returns the number of expected parallel Subscribers.

Returns:int

the number of expected parallel Subscribers

Annotations