如何从可观察获取的多个数据类型，因为只接受来自可观察的一个泛型类型<T>

Question

我们已经知道 Observable 只能有一个参数作为其泛型类型。观察 我假设我有 2 个网络调用，返回 2 种数据类型：UserResponse和WorkResponse。 我想逐步调用 2 个这样的 API，getUser 然后 getWork。 最后我订阅了它们，只得到了一种数据类型，显然这是WorkResponse，因为 getWork 是上游Observable<WorkResponse>中的最后一个 API 调用。 但是在订阅代码块中，我想同时获得UserResponse和WorkResponse。那么我该如何才能做到这一点呢？

1 - 有人说我应该创建一个容器类来包含UserResponse和WorkResponse然后我可以在订阅代码块中从该容器中获取这些数据类型。

2 - 创建一个临时变量来保存 userResponse，然后从 subscibe 代码块访问它，如下所示：

class MainActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
var tempUserResponse: UserResponse? = null
Observable.just("Prepare call API")
.flatMap {
apiGetUser()
}.flatMap { userResponse ->
tempUserResponse = userResponse // Save temporarily userResponse to pass it to subscribe code block
apiGetWork()
}.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe { workResponse ->
Log.e("TAG", "userResponse = " + tempUserResponse)
Log.e("TAG", "workResponse = " + workResponse)
}
}
private fun apiGetUser(): Observable<UserResponse> {
// Fake API to get User
return Observable.just(UserResponse())
}
private fun apiGetWork(): Observable<Work> {
// Fake API to get Work
return Observable.just(Work())
}
class Work
class UserResponse
}

3 - 有没有其他方法？ 请给我答案，非常感谢！

编辑：谢谢你们所有的回答，伙计们！您的所有答案在实现方式(使用nested flatMap或使用zip(上可能有所不同，但我们都需要使用 3rd 类作为我们需要的所有对象的容器类。 内置容器类，我们有：Pair<A, B>和Triple<A, B, C>.如果我们需要更多参数，我们必须创建自己的参数

Answer 1

您可以使用 zip 从 2 个结果中获取一个对象：

public class MergedObject{
private Work workResponse;
private UserResponse userResponse;
MergedObject(final Work workResponse, final UserResponse userResponse){
this.workResponse= workResponse;
this.userResponse= userResponse;
}
// getter / setter
}

然后

Observable.just("Prepare call API")
.flatMap {
apiGetUser()
}.zipWith(apiGetWork(), ( userResponse, workResponse ) ->
return new MergedObject(workResponse, userResponse)
).subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe { mergedObject->
Log.e("TAG", "userResponse = " + mergedObject.userResponse)
Log.e("TAG", "workResponse = " + mergedObject.workResponse)
}

(在没有任何测试的情况下编写，您可能需要稍微适应一下(

Answer 2

您可以重载flatmap并执行以下操作：

fun test() {
Observable.just("Prepare call API")
.flatMap {
apiGetUser()
}.flatMap(
Function<UserResponse, Observable<Work>> {
return@Function apiGetWork()
},
BiFunction<UserResponse, Work, Pair<UserResponse, Work>> { userResponse, work ->
Pair(userResponse, work)
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe { response ->
Log.e("TAG", "userResponse = " + response.first.name)
Log.e("TAG", "workResponse = " + response.second.name)
}
}
private fun apiGetUser(): Observable<UserResponse> {
// Fake API to get User
return Observable.just(UserResponse())
}
private fun apiGetWork(): Observable<Work> {
// Fake API to get Work
return Observable.just(Work())
}
class Work {
val name = "world"
}
class UserResponse {
val name = "hello"
}

基本上返回一个Pair<UserResponse, Work>:)