Vert.xイベントループを使用してRxJavaの実行をスケジュールする方法

Question

VertexイベントループをRxJava実行のスケジューラとして使用できますか？何かVertxSchedulerはVert.xのイベントループベースのスケジューラのいくつかの種類でなければなりませんように...

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

...。

Answer 1

あなたがio.vertx.reactivex.RxHelperを使用してVert.xベースのスケジューラを作成することができますin Vert.x RxJava documentation説明したように：

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

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

プールのスレッドVert.xの労働者からのスケジューラを作成RxHelper.blockingScheduler(Vertx)方法もあります。