【发布时间】:2021-06-25 08:58:45
【问题描述】:
我正在尝试在我的登录功能中转换 Observable,但我不断收到此错误。这是我在 flatMap 上遇到的代码和错误
fun login(phoneNumber: String, password: String, deviceId: String) {
// remove previous subscriptions
disposables.clear()
// function to save userInfo and access token
val saveResponse = { response: LoginResponse ->
val user = response?.user
val token = response?.token
// userManager.updateToken(champion, token, deviceId)
}
// on success callback
val onSuccess = { isSuccess: Boolean ->
progressBarVisibility.postValue(false)
loginSuccess.postValue(isSuccess)
if (!isSuccess) errorMessage.postValue("An error occurred please try again.")
}
// on failure callback
val onError = { throwable: Throwable ->
val message = when (throwable) {
is HttpException -> when (throwable.code()) {
400 -> "Enter valid Phone Number or Password"
422 -> "Incorrect Phone Number or Password"
else -> throwable.toErrorMessage()
}
else -> "An Error Occurred."
}
// show error message
errorMessage.postValue(message)
progressBarVisibility.postValue(false)
}
val disposable = accountUseCase.login(LoginRequest(phoneNumber, password)).observeOnUI()
.doOnSubscribe { progressBarVisibility.postValue(true) }
.flatMap {
val resp = it.data
when (resp) {
null -> Single.just(false)
else -> saveResponse(it)
}
}
.subscribe(onSuccess, onError)
// add subscription to disposables
disposables.add(disposable)
}
错误
Type mismatch. Required: ((BaseResponse<LoginResponse>!) → SingleSource<out (???..???)>!)! Found: (BaseResponse<LoginResponse>!) → Any!
【问题讨论】:
-
你
when的一个分支正在返回一个单曲,saveResponse返回什么?