Wie konvertiert man einen asynchronen Anruf in eine Synchronisierung?

Question

Ich bin ziemlich neu in RxJava und ich möchte einen Methodenaufruf machen, der eine Observable, sync zurückgibt.

Dies ist die Methode Unterschrift:

JsonObject login(); 

Ich habe versucht, so etwas, aber es hat nicht funktioniert:

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

Wie kann ich es funktioniert?

Vielen Dank.

Answer 1

beobachtbare nach Design ist synchron, wenn Sie eine Operation Asynchronous möchten Sie eine der spezifischen Operatoren müssen. (OnSubscribe, onObserver, Puffer ....)

auch nicht verwenden, es sei denn toBlocking für Ihren Test , ist fast ein Anti-Muster, versuche stattdessen das Observer-Muster zu verwenden.

 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 
    } 

Wenn Sie einen Blick einige grundlegende Beispiele nehmen wollen werfen Sie einen Blick hier https://github.com/politrons/reactive