2017-12-06 12 views
1

Vert.x 이벤트 루프를 RxJava 실행을위한 스케줄러로 사용할 수 있습니까? VertxScheduler가 Vert.x 이벤트 루프 기반 스케줄러의 일종해야 뭔가 같은 ...Vert.x 이벤트 루프를 사용하여 RxJava 실행을 예약하는 방법

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

....

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) 방법을 만드는 스케줄러가 :

답변

2

으로는 io.vertx.reactivex.RxHelper를 사용 Vert.x 기반 스케줄러를 만들 수 있습니다 in Vert.x RxJava documentation을 설명했다.