java - RxJava : chaining results from map methods

Question

我使用 RxJava 有一段时间了，并且陷入了以下重复的模式:

source
 .map(a -> b)
 .map(b -> c)
 .map(d -> func(a,b,c))

如您所见，我需要在链的较低点上使用先前映射方法的一些结果。我不确定这是否是 Java 限制，因为 lambda 不能引用非最终的外部参数，或者这是对 Rx-Extensions 的内置限制。我当前的解决方案是使用包含 a、b、c 的包装器 - 并将每个包装器添加到 map 中，然后返回包装器类。但是这个方案感觉写不出来。

有没有更好的解决方案？

Answer 1

如果map s 直接相互跟随，您可以将它们压缩到一个 map 中，并将所有中间数据提供给最终函数:

source.map(a -> {
    T b = fa(a);
    U c = fc(b);
    return func(a, b, c);
})

在哪里T和 U是 b 的中间值类型和 c分别。