0

我将 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())}
    )
}

如何正确处理错误?谢谢

4

0 回答 0