c# – 有没有办法合并两个IObservable,如果B在A之前完成,它会停止结果(但反之亦然)？

我有两个IObservable序列,在完成之前最多会返回一个项目.我想合并它们,但是第一个序列通常会先完成,在极少数情况下可能会完成第二个序列.如果它完成第二,那么我想忽略它的输出.

normal case:
A       1
B       -  2
Result  1  2

Rare,"slow A" case:
A       -  1
B       2
Result  2

有一个简单的方法吗？我不知道根据IObservable触发最后一个OnNext过早结束合并序列的方法.我有的最好的解决方案是选择并返回一个元组,指示值来自哪个序列,并简单地忽略“B”结果后的所有内容.

解决方法

对于这种情况,以下应该有效：

var combined = A.takeuntil(B).Merge(B);