在RxJava中，链接可观察对象时如何传递变量？

Question

我正在使用RxJava链接异步操作，我想向下游传递一些变量：

Observable
   .from(modifications)
   .flatmap( (data1) -> { return op1(data1); })
   ...
   .flatmap( (data2) -> { 
       // How to access data1 here ?
       return op2(data2);
   })

这似乎是一种常见的模式，但我找不到有关它的信息。

Answer 1

flatmap可以使用第二个参数：

Observable.just("foo")
                .flatMap(foo -> Observable.range(1, 5), Pair::of)
                .subscribe(pair -> System.out.println("Result: " + pair.getFirst() + " Foo: " + pair.getSecond()));

资料来源：https://medium.com/rxjava-tidbits/rxjava-tidbits-1-use-flatmap-and-retain-original-source-value-4ec6a2de52d4

Answer 2

另一种可能性是将op1的结果映射到组织。阿帕奇。平民lang3.tuple。配对包含变量的，并传递：

Observable
   .from(modifications)
   .flatmap( (data1) -> {
       return op1(data1).map( obj -> { return Pair.of(data1,obj); });
   })
   ...
   .flatmap( (dataPair) -> { 
       // data1 is dataPair.getLeft()
       return op2(dataPair.getRight());
   })

它可以工作，但是将变量隐藏在Pair/Triple/中感觉有点不舒服...如果您使用Java6符号，它会变得非常冗长。

我想知道是否有更好的解决方案，也许一些RxJava操作员可以帮助？

Answer 3

我从Couchbase论坛得到的建议是使用嵌套的可观察对象：

Observable
    .from(modifications)
    .flatmap( (data1) -> { 
        return op1(data1)
            ...
            .flatmap( (data2) -> { 
                // I can access data1 here
                return op2(data2);
            })
        });

编辑：我会将此标记为公认答案，因为它似乎是最推荐的答案。如果处理太复杂，无法嵌套所有内容，也可以通过函数调用检查解决方案。