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 java.lang.Object implements SchedulerMultiWorkerSupport.WorkerCallback
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.reactivestreams.Subscriber<T>[]
parents
(package private) org.reactivestreams.Subscriber<? super T>[]
subscribers
-
Constructor Summary
Constructors Constructor Description MultiWorkerCallback(org.reactivestreams.Subscriber<? super T>[] subscribers, org.reactivestreams.Subscriber<T>[] parents)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onWorker(int i, Scheduler.Worker w)
Called with the Worker index and instance.
-
-
-
Method Detail
-
onWorker
public void onWorker(int i, Scheduler.Worker w)
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
-
-