DisposableObserver <> не является подтипом Observer <>

Question

Я пытаюсь преобразовать этот урок по RxJava / RxAndroid в RxKotlin / RxAndroid.При методе из примера 5 я получаю сообщение об ошибке

Моя функция 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

Все, что мне было нужно, это заявление о возврате (с картинки ниже). Спасибо за ответ