vertx / io.vertx.reactivex / RxHelper

RxHelper

open class RxHelper

Author
Julien Viet

Constructors

<init>

RxHelper()

Functions

blockingScheduler

open static fun blockingScheduler(vertx: Vertx): 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.

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.

scheduler

open static fun scheduler(vertx: Vertx): Scheduler

Create a scheduler for a io.vertx.core.Vertx object, actions are executed on the event loop.

open static fun scheduler(context: Context): Scheduler

Create a scheduler for a io.vertx.core.Context, actions are executed on the event loop of this context.