Class ParallelRunOn.MultiWorkerCallback
java.lang.Object
io.reactivex.rxjava3.internal.operators.parallel.ParallelRunOn.MultiWorkerCallback
- All Implemented Interfaces:
SchedulerMultiWorkerSupport.WorkerCallback
- Enclosing class:
ParallelRunOn<T>
final class ParallelRunOn.MultiWorkerCallback
extends Object
implements SchedulerMultiWorkerSupport.WorkerCallback
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionMultiWorkerCallback
(org.reactivestreams.Subscriber<? super T>[] subscribers, org.reactivestreams.Subscriber<T>[] parents) -
Method Summary
Modifier and TypeMethodDescriptionvoid
onWorker
(int i, Scheduler.Worker w) Called with the Worker index and instance.
-
Field Details
-
subscribers
-
parents
-
-
Constructor Details
-
MultiWorkerCallback
-
-
Method Details
-
onWorker
Description copied from interface:SchedulerMultiWorkerSupport.WorkerCallback
Called with the Worker index and instance.- Specified by:
onWorker
in interfaceSchedulerMultiWorkerSupport.WorkerCallback
- Parameters:
i
- the worker index, zero-basedw
- the worker instance
-