Как установить HandlerThread, чтобы быть потоком наблюдателя
В приведенном ниже коде я вызываю метод displayAllMovies() из потока обработчика. Для Single.just в приведенном ниже коде, как я могу указать поток наблюдателя "поток, в котором будет вызываться onSuccess", чтобы он был таким же, как HandlerThread?
код:
private void displayAllMovies() {
Log.v(TAG_LOG, "->displayAllMovies is called");
Single<Boolean> justSingleObservable =
Single.just(this.isMoviePersistentDatabaseEmpty())
...
...
})
.delay(10, TimeUnit.SECONDS);
justSingleObservable.subscribeOn(Schedulers.io());
justSingleObservable.observeOn(Schedulers.io());
justSingleObservable.subscribe(new SingleObserver<Boolean>() {
@Override
public void onSubscribe(Disposable disposable) {
Log.v(TAG_LOG + "->" + "SingleObservable", "onSubscribe");
Log.d(TAG_LOG + "->" + "SingleObservable", " disposable: " +
disposable);
Log.d(TAG_LOG + "->" + "SingleObservable", "
disposable.isDispose: " + disposable.isDisposed());
}
@Override
public void onSuccess(Boolean aBoolean) {
Log.v(TAG_LOG + "->" + "SingleObservable", " onSuccess");
Log.d(TAG_LOG + "->" + "SingleObservable", " bBoolean: " +
aBoolean);
}
@Override
public void onError(Throwable e) {
Log.v(TAG_LOG + "->" + "SingleObservable", " onError");
Log.d(TAG_LOG + "->" + "SingleObservable", " e.getMessage: " +
e.getMessage());
}
});
}