io.reactivex.exceptions.UndeliverableException: The exception could not be delivered to the consumer because it has already canceled/disposed the flow or the exception has nowhere to go to begin with. Further reading: https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0#error-handling | kotlin.TypeCastException: null cannot be cast to non-null type yodgorbekkomilov.edgar.spectrumtask.adapter.MemberAdapter
at io.reactivex.plugins.RxJavaPlugins.onError(RxJavaPlugins.java:367)
at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:65)
at io.reactivex.internal.operators.single.SingleObserveOn$ObserveOnSingleObserver.run(SingleObserveOn.java:81)
at io.reactivex.android.schedulers.HandlerScheduler$ScheduledRunnable.run(HandlerScheduler.java:124)
at android.os.Handler.handleCallback(Handler.java:873)
at android.os.Handler.dispatchMessage(Handler.java:99)
at android.os.Looper.loop(Looper.java:201)
at android.app.ActivityThread.main(ActivityThread.java:6820)
at java.lang.reflect.Method.invoke(Native Method)
at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:547)
at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:922)
Caused by: kotlin.TypeCastException: null cannot be cast to non-null type yodgorbekkomilov.edgar.spectrumtask.adapter.MemberAdapter
at yodgorbekkomilov.edgar.spectrumtask.MemberActivity.onResponse(MemberActivity.kt:81)
at yodgorbekkomilov.edgar.spectrumtask.MemberActivity.access$onResponse(MemberActivity.kt:25)
at yodgorbekkomilov.edgar.spectrumtask.MemberActivity$onCreate$3.accept(MemberActivity.kt:44)
at yodgorbekkomilov.edgar.spectrumtask.MemberActivity$onCreate$3.accept(MemberActivity.kt:25)
at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
... 9 more

Guys anyone had the same issue

Try RxJavaPlugins.setErrorHandler

ребята вопрос - есть примерно такое Observable.someFunc().map(x->x*2).observeOn(Schedulers.io()).map(x->x+1). subscribe(...) будут выполнятся map (обе) если я это запускаю из MainUI Android?

А зачем между мапами смена шедулера?

Это не мне ) в тесте был вопрос

Вот сижу и думаю, вообще о смысле этой конструкции

Парни вопрос есть, изучаю rx по урокам в интернете, везде почти одни и те же примеры, из которых не понятно как сделать запрос к базе через rxjava в потоке, я так понял на вход цепочки операторов rx должно поступать не данные с базы, а входные параметры запроса, а запрос к базе уже должен идти в каком-то операторе  rx? Как это сделать, через какой оператор и можно пример если есть посмотреть

просто обычный запрос типа селекта засовываешь в observable (можно и сингл, че хочешь как говориться), а уже для обсерва ставишь потоки, подписки и вообще что нужно

А его через какой оператор запихнуть? Flatmap?

типа такого (без компа, точно не напишу) - Observable.create<DBResponse> {
                       it.onNext(appDB.selectAllJunDevs())
                       it.onComplete()
                   }.observeOn(...).subscribeOn(...).subscribe{}

М, в onNext уже запрос и через return другим операторам набор уже передаю, правильно понял?

нет в onNext ты значение передаешь из базы, а что-то делаешь в subscribe (методы вызываешь и прочее)

https://startandroid.ru/ru/19-course/rxjava/435-urok-1.html на стартандроиде же норм уроки

Ну я это и имел ввиду, onNext, получает параметры запроса в БД, внутри происходит запрос и получение набора, а в subscribe его обработка

Спасибо, все на места стало👍

А нет я с just перепутал

Just вроде один параметр принимает и передает цепочке его

это примерно одно и тоже, только я передаю значение в onNext, для того чтобы запрос выполнить в фоновом потоке (ну или в каком тебе надо, тот что укажешь в observeOn)