Verwendung der Vert.x-Ereignisschleife zur Planung der RxJava-Ausführung

Question

Kann die Vert.x-Ereignisschleife als Scheduler für die RxJava-Ausführung verwendet werden? So etwas wie ...

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

... wo VertxScheduler sollte eine Art Vert.x Ereignisschleife Scheduler sein.

Answer 1

Wie beschrieben in Vert.x RxJava documentation Sie können Vert.x Scheduler erstellen io.vertx.reactivex.RxHelper mit:

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

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

Es gibt auch RxHelper.blockingScheduler(Vertx) Verfahren zu schaffen Scheduler von Vert.x Worker-Threads Pool.