gateway возвращает Single

.switchIfEmpty до мапа надо судя по логике

Добрый день. Подскажите пожалуйста как выполнить метод onNext в рабочем потоке, а onError в главном? Вариант вызывать ошибку в runOnUI нормальный ?

Observable.just(responseBody)
               .subscribeOn(Schedulers.io())
               .subscribe(new Observer<ResponseBody>() {
                   @Override
                   public void onSubscribe(Disposable d) {}

                   @Override
                   public void onNext(ResponseBody responseBody) {
                           createFileApk(responseBody, apkFile);}

                   @Override
                   public void onError(Throwable e) {
                       showErrorDownloading(e);}

                   @Override
                   public void onComplete() {}
               });

не совсем понял, но по идее вот это нужно .observeOn(AndroidSchedulers.mainThread())

Тогда и onNext будет происходить в главном потоке, так ведь?

если честно, сейчас нет особо времени обьяснить, но не должно. В каком подписываешься в том и выполняется, и результат уже в поток observeOn

скорее всего придется раздваивать поток и обработку ошибок проводить в ином потоке. а подписчик уже будет работать только с результатом, без ошибки

Подскажите пожалуйста как создать BehaviourSubject, чтобы он получал данные от Single грамотно? Не могу найти информацию. Есть какие-нибудь хорошие учебники, где можно полезную информацию найти?

Заранее извиняюсь за копипаст с другого чата. понимаю, что вопрос не очень, но все таки: могу ли передать текущий поток сюда как нибудь? Чтоб результат он слушал в текущем потоке, а не создавал новую?

Если в треде нет какого нибудь лупера то анрил

да, анрил. пришлось в маин кидать результаты из двух процессов((((

Всегда можно свой тред с лупером запустить. Если андроид то есть HandlerThread

то есть гуглить хандлер? спасибо, ща попробую

HandlerThread* )

У рхандроид есть метод. AndroidSchedulers.from(myHandlerThread.getLooper()) можно сделать

Можно вообще так запилить.
class VideoStreamScheduler {
   private HandlerThread handlerThread = new HandlerThread("video-thread");
   Scheduler scheduler = AndroidSchedulers.from(handlerThread.getLooper());
}

такой вот пример я видел - но немного поленился

Ну кода не много) и будет свой шедулер для конкретных целей

ты же предлагаешь что-то вроде такого?