vertx / io.vertx.reactivex / RxHelper / blockingScheduler

blockingScheduler

open static fun blockingScheduler(vertx: Vertx): Scheduler

Create a scheduler for a io.vertx.core.Vertx object, actions can be blocking, they are not executed on Vertx event loop.

Parameters

vertx - the vertx object

Return
the scheduler

open static fun blockingScheduler(vertx: Vertx, ordered: Boolean): Scheduler

Create a scheduler for a io.vertx.core.Vertx object, actions can be blocking, they are not executed on Vertx event loop.

Parameters

vertx - the vertx object

ordered - if true then if when tasks are scheduled several times on the same context, the executions for that context will be executed serially, not in parallel. if false then they will be no ordering guarantees

Return
the scheduler

open static fun blockingScheduler(executor: WorkerExecutor): Scheduler

Create a scheduler for a io.vertx.core.WorkerExecutor object, actions are executed on the threads of this executor.

Parameters

executor - the worker executor object

Return
the scheduler