Allows retrieving multiple workers from the implementing io.reactivex.Scheduler in a way that when asking for at most the parallelism level of the Scheduler, those io.reactivex.Scheduler.Worker instances will be running with different backing threads.

History: 2.1.8 - experimental

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static interface	SchedulerMultiWorkerSupport.WorkerCallback The callback interface for the `SchedulerMultiWorkerSupport#createWorkers(int, WorkerCallback)` method.

Method Summary

Modifier and Type	Method and Description
public void	createWorkers(int the number of workers to create, positive number, SchedulerMultiWorkerSupport.WorkerCallback the callback to send worker instances to callback) Creates the given number of `io.reactivex.Scheduler.Worker` instances that are possibly backed by distinct threads and calls the specified `Consumer` with them.

Method Detail

createWorkers back to summary

createWorkers	back to summary
public void createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback) Creates the given number of `io.reactivex.Scheduler.Worker` instances that are possibly backed by distinct threads and calls the specified `Consumer` with them. Parameters number:int the number of workers to create, positive callback:SchedulerMultiWorkerSupport.WorkerCallback the callback to send worker instances to

public void createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback)

Creates the given number of io.reactivex.Scheduler.Worker instances that are possibly backed by distinct threads and calls the specified Consumer with them.

Parameters

number:int: the number of workers to create, positive
callback:SchedulerMultiWorkerSupport.WorkerCallback: the callback to send worker instances to

io.reactivex.internal.schedulers back to summary

public Interface SchedulerMultiWorkerSupport.WorkerCallback

Known Direct Implementers: io.reactivex.internal.operators.parallel.ParallelRunOn.MultiWorkerCallback

The callback interface for the SchedulerMultiWorkerSupport#createWorkers(int, WorkerCallback) method.

Method Summary

Modifier and Type	Method and Description
public void	onWorker(int the worker index, zero-based index, Scheduler.Worker the worker instance worker) Called with the Worker index and instance.

Method Detail

onWorker	back to summary
public void onWorker(int index, Scheduler.Worker worker) Called with the Worker index and instance. Parameters index:int the worker index, zero-based worker:Scheduler.Worker the worker instance

onWorker

back to summary

public void onWorker(int index, Scheduler.Worker worker)

Called with the Worker index and instance.

Parameters

index:int: the worker index, zero-based
worker:Scheduler.Worker: the worker instance