rxjava 按条件收集对象并等待另一个 observable答案

【问题标题】：rxjava collect objects by condition and wait for another observablerxjava 按条件收集对象并等待另一个 observable
【发布时间】：2016-09-01 12:51:20
【问题描述】：

Need process 我有 2 个可以产生橙色和绿色对象（1 和 2）的 observables。这两个对象一对（绿色激活橙色由计时器其他触发器）。

有时我会遇到不同的 observables 可以发射（产生）相同的橙色对象（A 和 B 内部相同）的情况。在这种情况下，我需要检查 A 是否等于 B 并留下一个对象等待绿色激活器（当然，A 和 B 可能不同）。如果会出现 A 或 B 的绿色激活器，我需要检查绿色激活器是否适合橙色，然后执行操作。

我认为我应该使用 PublishObjects 并将绿色和橙色对象组合在一起（如果不适合则不要检查条件和左侧对象），甚至不知道如何将 2 个橙色对象组合在一起。请猜猜怎么做？

【问题讨论】：

标签： rx-java

【解决方案1】：

我找到了另一种关于简单 RxJava 运算符组合的解决方案（我的项目的特定架构），但我调查了以下两种可能的解决方案：
1）编写自己的运营商（我还没有准备好与生产商合作），这个link可以帮助你；
2) 使用最新的 combineLatest() 运算符和繁重的函数代码（我看到两个可观察对象的两个列表，它们的组合逻辑和超时清理）；

【讨论】：