我对如何正确使用Single和Completable感到困惑。我有一个get方法,它返回Single,另一个方法只是保存数据,什么也不返回(Completable)代码如下:
fun getUserInfo() : Single<UserInfo>
fun save(token: Token) : Completable
fun initialize() {
getUserInfo()
.flatMap {
// Get token from UserInfo : val token = userInfor.getToken()
// Call save(token: Token) method to save data
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(
onSuccess = {
// HERE: Using UserInfo to do somtehing
},
onError = {
Log.d(it)
}
)
}
如何在flatMap块中编写代码? (或者是否有其他操作员适合该用例?)谢谢
您可以使用flatMapCompletable
:
fun initialize() {
getUserInfo()
.flatMapCompletable { userInfo: UserInfo ->
// save userInfo somewhere. i.e:
[email protected] = userInfo
val token = userInfo.getToken()
return@flatMapCompletable save(token)
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(
onComplete = { // <--------- this becomes onComplete instead of onSuccess
// Here, you can use userInfo that you saved
},
onError = {
Log.d(it)
}
)
}
请注意,在您的subscribeBy(...)
方法中,不要忘了将回调函数名称从onSuccess(...)
更改为onComplete(...)
,因为您正在将单个转换为可完成。
或者,如果要将userInfo
保留为局部变量,则可以使用toSingleDefault(...)
将其从save(...)
方法中的可完成完成的操作向下游发出:
fun initialize() {
getUserInfo()
.flatMap { userInfo: UserInfo -> // change back to flatmap
val token = userInfo.getToken()
return@flatMap save(token).toSingleDefault(userInfo)
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeBy(
onSuccess = { userInfo: UserInfo ->
// do something with userInfo ...
},
onError = {
Log.d(it)
}
)
}