创建结合两个但由一个统治的可观察性
我需要使用以下规则将两个可观察到的东西A和B组合起来：
- 组合可观察物的类型必须是
可能是 - A可以多次发射或不发射
- B可能发射1次或不发射
- 只要B没有发射任何东西，组合的可观测物就不会发射任何东西。
- 当B发射时，如果A已经发射，则A的最后结果将由组合可观测器发射。如果A尚未发出，
Maybe.empty()将发出。
共有1个答案
我不认为这可以简单地用默认的RxJava运算符来完成，但是作为一个变通方法，您可以在开头发出一个带有值的“空元素”。然后，使用CombineLatest，您可以检查发出的元素是否为“empty element”，如果是，则将其转换为Maybe.empty()，如下所示（例如Observable
):
Observable.combineLatest(
a.startWith("EMPTY"),
b,
BiFunction<String, String, String> { a1, b1 -> a1 })
.firstElement()
.flatMap{ if (it == "EMPTY") Maybe.empty() else Maybe.just(it) }
-
问题内容： 我正在尝试在JavaFX 8中创建一个，需要一个。我不知道如何创建一个……但是，如果我尝试： 我收到一个错误消息，说它无法实例化，因为它是抽象的。可以理解的 如果我查看该文档，可以看到，但是我做不到： 因为没有适用的构造函数。显然我需要传递给，这很奇怪，因为我无法创建。 我不确定如何解密。如果我尝试 出于绝望，我得到了一个更加复杂的错误。 也不起作用。它以某种方式起作用（但显然使用了不
-
我有一个id列表，并且有一个方法，它接受id并返回可观察的 假设我有用户id（1），我需要使用此方法更新他的配置文件
-
我需要将另一个改装请求中的图像合并到其特定系列中。听起来很简单的任务把我带进了反应式的地狱，没有一丝希望。 具体来说，我还通过可观察创建服务，因为我需要获取身份验证令牌来创建服务。 我的尝试基于以下答案：https://stackoverflow.com/a/28418503/2192545. 我有点不知所措。我只是在Observable的Func2部分得到了“无法推断函数接口类型”。在IDE中，
-
我对RxJS很陌生，所以如果这个问题已经得到回答，我提前道歉。 我有一个Angular 2应用程序，在其中一个组件中有一个普通对象。我将UI绑定到这个对象。我想做的是能够捕获对这个对象的所有更改，无论它们来自代码还是来自用户更改其中一个字段。 我正在查看可观察对象，但似乎只有通过Emit方法推送新对象时，订阅者才能接收通知。例如，在属性绑定到输入字段的情况下，这将如何工作？ 有更好的方法吗？ 这是
-
我将Ionic3与一个一起使用。我有下面的函数，出于某种原因，即使该函数只被调用一次，第三行也会被触发两次。 问题 这引起了一个问题，因为正在获取第二个订阅的值，并且第一个订阅丢失，不允许我取消订阅。 问题 如何创建一个只有一个订阅的
-
问题：我有一个功能，用户可以输入一个查询字符串，我创建了两个可观察对象，一个用于查询本地DB，另一个用于从API获取结果。这两个操作必须并行运行。我需要尽快显示DB中的结果，当API结果返回时，我需要进行检查以删除本地结果中的重复项。 我的方法：CombineTest似乎是最接近我需要的东西。但问题是，只有当两个可见光都发出结果时，它才会发出。我想我要找的是CombineLatest和Concat