vertx / io.vertx.reactivex.core / RxHelper

RxHelper

open class RxHelper

Author
Julien Viet

Constructors

<init>

RxHelper()

Functions

blockingScheduler

open static fun blockingScheduler(executor: WorkerExecutor): Scheduler

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

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

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

deployVerticle

open static fun deployVerticle(vertx: Vertx, verticle: Verticle): Single<String>

Deploy a verticle you have created yourself, using an RxJava vertx instance.

open static fun deployVerticle(vertx: Vertx, verticle: Verticle, options: DeploymentOptions): Single<String>

Like #deployVerticle(Vertx, Verticle), but DeploymentOptions are provided to configure the deployment.

scheduler

open static fun scheduler(context: Context): Scheduler

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

open static fun scheduler(vertx: Vertx): Scheduler

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