Vert.x未来からObservableを作成するには？

Question

私は同じ問題に複数のハンドラを設定する必要があるので、io.vertx.core.Futureのインスタンスを持っています。この問題によれば、https://github.com/eclipse/vert.x/issues/1920はObservablesとなります。

しかし、私は未来からObservableを得る方法が見つけられませんでした。

私はrx.Observable.from(Future)を試しましたが、Java Futureではないため動作しません。

私はRxHelperを見て、メソッドはFutureをパラメータとして取ります。

私には何が欠けていますか？どんな助けもありがとうございます。

Answer 1

あなたはObservableFutureを作成し、元のFuture

import io.vertx.core.Future 
import io.vertx.rx.java.RxHelper 

def myFuture = Future.<String> future() 

def obsFut = RxHelper.observableFuture() 
myFuture.setHandler(obsFut.toHandler()) 

obsFut.subscribe({ s -> 
    println "Hello $s" 
}) 

myFuture.complete("John") 

印刷物のハンドラとしてそのハンドラを使用することができます

Hello John