【发布时间】:2019-01-06 08:08:06
【问题描述】:
代码如下:
getUsersObservable()
.subscribeOn(Schedulers.io())
//.observeOn(AndroidSchedulers.mainThread())
.map { user: User ->
user.email = String.format("%s@rxjava.wtf", user.name)
user.name = user.name!!.toUpperCase()
}
.subscribe(object : Observer<User> {
override fun onComplete() {
}
override fun onSubscribe(d: Disposable) {
}
override fun onNext(t: User) {
}
override fun onError(e: Throwable) {
}
})
我收到以下错误:
/Users/johann/Work/Dev/Kotlin/rxjava-walkthrough-kotlin/app/src/test/java/ktplay/RxKotlinPlay.kt: (49, 14): 下列函数都不能用 提供的参数:@CheckReturnValue @SchedulerSupport public final fun subscribe(p0: ((Unit) -> Unit)!): 一次性的!定义在 io.reactivex.Observable @SchedulerSupport 公共最终乐趣 subscribe(p0: Observer): 定义的单位 io.reactivex.Observable @CheckReturnValue @SchedulerSupport 公共 最终乐趣订阅(p0:消费者!):一次性!定义在 io.reactivex.Observable
这个错误发生在subscribe的那一行。
【问题讨论】: