Как установить 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());
        }
    });
 }

0 ответов

Другие вопросы по тегам