RxJava2 и Kotlin: OnErrorNotImplementedException - PullRequest
Новая
       28

RxJava2 и Kotlin: OnErrorNotImplementedException

0 голосов
/ 15 мая 2018

Я использую RxJava2 с Kotlin. Я не знаю почему, но у меня всегда есть эта ошибка:

io.reactivex.exceptions.OnErrorNotImplementedException: операция не реализована: не реализована

Поэтому я добавляю своему подписчику обратный вызов onError, но теперь у меня появляется эта ошибка (внутри onError):

kotlin.NotImplementedError: Операция не реализована: не реализована

Это мой код: 

override fun getOpenBar(): Observable<List<Bar>> {

    val query: ParseQuery<ParseObject> = ParseQuery.getQuery("Bar")
    query.whereEqualTo("isOpen",true)
    return ParseObservable.find(query).toList().map { BarMapper.map(it) }.toObservable()
}

В моем докладчике: 

override fun onAttach(view: V?) {
    super.onAttach(view)
    getView()?.printDate()
    getView()?.showProgress()
    interactor?.getBar()?.compose(schedulerProvider.ioToMainObservableScheduler())?.subscribeBy(
            onNext = {if (it.isEmpty()) getView()?.printNoResult()
            else getView()?.printBarResult(it)
                getView()?.hideProgress()},

            onError = {Log.d("TEST",it.toString())}
    )
}

Как правильно обработать ошибку? Спасибо

...