Package io.reactivex.rxjava3.internal.operators.parallel

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
    Modifier and Type
    Field
    Description
    (package private) final org.reactivestreams.Subscriber<T>[]
    parents
     
    (package private) final 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

    Modifier and Type
    Method
    Description
    void
    onWorker(int i, Scheduler.Worker w)
    Called with the Worker index and instance.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • subscribers

      final org.reactivestreams.Subscriber<? super T>[] subscribers

    • parents

      final org.reactivestreams.Subscriber<T>[] parents

  • Constructor Details

    • MultiWorkerCallback

      MultiWorkerCallback(org.reactivestreams.Subscriber<? super T>[] subscribers, org.reactivestreams.Subscriber<T>[] parents)

  • Method Details