Warum wird das Abonnement nicht in einem neuen Thread ausgeführt?

Question

Ich habe Aufgabe wie folgt aus:

Observable.just(getMessagesFromDb()). 
    subscribeOn(Schedulers.newThread()). 
    observeOn(AndroidSchedulers.mainThread()). 
    subscribe(incomingMessages -> { 
    //do something 
    }); 

wo getMessagesFromDb Methode ist synchron Nachrichten bekommen, ohne innerhalb Multithreading. Nach Angaben der RxAndroid Dokumentation für subscribeOn Methode:

Asynchron abonnieren Beobachter auf diese Observable auf dem Scheduler angegeben

Und es ist meine Frage - warum die Datenbankabfrage auf Haupt-Thread ausgeführt wird? Wie man es asynchron macht?

Answer 1

Was sehen Sie unten ist eine leicht modifizierte Version des Codes mit getMessagesFromDb() genannt einen Rückgabewert einer Variablen zuzuweisen:

Object data = getMessagesFromDb(); 
Observable.just(data). 
    subscribeOn(Schedulers.newThread()). 
    observeOn(AndroidSchedulers.mainThread()). 
    subscribe(incomingMessages -> { 
     //do something 
    }); 

Es ist genau, wie Observable.just Werke und getMessagesFromDb() in der Tat in dem Haupt-Thread aufgerufen wird (wie Sie es im Hauptthread nennen).

Sie haben es Observable.fromCallable Verfahren aufzuschieben wie folgt verwendet:

Observable.fromCallable(() -> getMessageFromDb()). 
      subscribeOn(Schedulers.newThread()). 
      observeOn(AndroidSchedulers.mainThread()). 
      subscribe(incomingMessages -> { 
       //do something 
      }); 

Bitte beachten Sie, dass Sie Observable.defer statt Observable.fromCallable verwenden können, aber es ist ein wenig komplizierter:

Observable.defer(() -> Observable.just(getMessageFromDb())) 

Die bisherige Version dieser Antwort verwenden Observable.create. Aber es ist kompliziert, mit dieser Methode ein Observable zu erstellen. Versuchen Sie immer bevorzugen Observable.defer oder Observable.fromCallable