延迟的可观察调用
延迟的可观察调用
提问于 2017-06-28 09:37:21
我有5个观察者说
Observable<String> obs1 = getObs1();
Observable<String> obs2 = getObs2();
Observable<String> obs3 = getObs3();
Observable<String> obs4 = getObs4();
Observable<String> obs5 = getObs5();getObsX()的实现是通过RxNetty进行网络调用。
因为所有的调用都是独立的，所以我需要同时启动它们。
在完成obs1和obs2之后，我需要开始调用getObs6()，它依赖于obs1和obs2。我可以做这样的事情。
Observable.zip(obs1, obs2, (obs1, obs2) -> {
return getObs6()
})
;一旦我获得了obs6，我就需要使用obs1、obs2、obs3、obs4、obs5和obs6来获取obs7。
那么，我如何才能订阅两次obs1，一次是为了获得obs5，另一次是为了获得
回答 1
Stack Overflow用户
发布于 2017-06-28 14:59:42
很抱歉，我不是一个Java开发人员，所以我将用c#给你答案--我希望这没问题。
就像这样做一样简单：
var query =
from i1 in getObs1()
from i2 in getObs2()
from i3 in getObs3()
from i4 in getObs4()
from i5 in getObs5()
from i6 in getObs6(i1, i2)
from i7 in getObs7(i1, i2, i3, i4, i5, i6)
select i7;我使用以下代码对此进行了测试：
IObservable<int> getObs1() => Observable.Return(1);
IObservable<int> getObs2() => Observable.Return(2);
IObservable<int> getObs3() => Observable.Return(3);
IObservable<int> getObs4() => Observable.Return(4);
IObservable<int> getObs5() => Observable.Return(5);
IObservable<int> getObs6(int x, int y) => Observable.Return(x * y);
IObservable<int> getObs7(params int[] x) => Observable.Return(x.Aggregate((j, k) => j * k));我得到了240的正确答案。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/44792349
复制相关文章
相似问题
腾讯云开发者
