DisposableObserver<> 不是 Observer<> 的子类型

Question

我正在尝试将 this RxJava/RxAndroid lesson 转换为 RxKotlin/RxAndroid。在 Example5 的方法中，我从图片中得到错误

我的 getNotesObservable() 函数是：

fun getNotesObservable(): Observable<Note>{
    val notes: List<Note> = prepareNotes()
    return Observable.create {
        for (note in notes) {
            if (!it.isDisposed){ // onNext only if observable is not disposed
                it.onNext(note)
            }
        }

        if (!it.isDisposed) {
            it.onComplete()
        }
    }
}

错误的部分是：

disposable.add(
        getNotesObservable().subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .map{
                it.note = it.note.toUpperCase()
            }
            .subscribeWith(getNotesObserver())
    )

那么，我应该在我的代码中更改什么？

Answer 1

我只需要 return 声明（来自下图）感谢

DisposableObserver<> 不是 Observer<> 的子类型

DisposableObserver<> is not subtype of Observer<>

kotlin

rx-android