非同期呼び出しを同期に変換するには？

Question

私はRxJavaを新しく使いました。私はObservableを返すメソッド呼び出しをしたいと思います。

これは、メソッドのシグネチャである：

JsonObject login(); 

私はこのような何かを試してみましたが、それはうまくいきませんでした：

public JsonObject login() { 
    return eventBus 
    .sendObservable(...) 
    .toBlocking().first().body(); 
} 

どのように私はそれを動作させることができますか？

ありがとうございます。

Answer 1

設計によって観察は、任意の操作非同期をしたい場合は、特定の演算子のいずれかを使用する必要があり、同期である。（onSubscribe、onObserver、バッファ....）

また、あなたのテストのためのない限りtoBlockingを使用していませんほとんどの反パターンですが、代わりにObserverパターンを使用してみてください。

 public void main(String args[]){ 

     login().subscribe(jsonObject-> do Whatever you need); 
    } 


    public Observable<JsonObject> login() { 
     return eventBus.sendObservable(...) --> I guess this call return an Observable 
    } 

あなたは見にいくつかの基本的な例を取りたい場合は、具体的には（あなたが取得エラー）が動作しません何