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