How to use Vert.x event loop to schedule RxJava execution

1
votes

Is it possible to use Vert.x event loop as scheduler for RxJava execution? Something like...

Observable.range(1, 10).flatMap(it ->
  Observable.just(it)
).subscribeOn(new VertxScheduler()).
  subscribe(System.out::println);

...where VertxScheduler should be some kind of Vert.x event loop based scheduler.

1
rx-javavert.x

1 Answers

3
votes

As described in Vert.x RxJava documentation you can create Vert.x based scheduler using io.vertx.reactivex.RxHelper:

Vertx vertx = Vertx.vertx();
Scheduler scheduler = RxHelper.scheduler(vertx);

Observable.range(1, 10).flatMap(it ->
  Observable.just(it)
).subscribeOn(scheduler).
  subscribe(System.out::println);

There is also RxHelper.blockingScheduler(Vertx) method creating scheduler from Vert.x worker threads pool.