不能使用提供的参数调用下列函数

Question

代码如下：

getUsersObservable()
    .subscribeOn(Schedulers.io())
    //.observeOn(AndroidSchedulers.mainThread())
    .map { user: User ->
        user.email = String.format("[e-mail]", 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)！）：disable！在io.reactivex.observable@SchedulerSupport public final fun subscribe(p0:Observer):在io.reactivex.observable@CheckReturnValue@SchedulerSupport public final fun subscribe(p0:Consumer！）中定义的单位：Disposable！在io.reactivex.observable中定义

此错误发生在带有subscribe的行上。

Answer 1

当前，map运算符采用user并返回unit而不是user。它应该是这样的：

.map { user: User ->
    user.email = String.format("[e-mail]", user.name)
    user.name = user.name!!.toUpperCase()
    user
}