Rx.NET中如何创建在两个IObservable<T>均完成时发出完成信号的IObservable<Unit>？

嗨，我太懂这种从Reactor转Rx.NET时找对应操作符的困惑了！你要实现的「等两个IObservable<T>都完成后，只发出一个完成相关的信号（比如Unit），全程不输出其他值」的需求，Rx.NET里有几种非常惯用的写法，我给你拆解下：

方案一：用WhenAll配合值转换（最接近Reactor的组合逻辑） #

Reactor里then().and()本质是等待多个「完成信号」，Rx.NET里的Observable.WhenAll就是干这个的——它会等待所有传入的Observable全部成功完成（如果其中一个出错，会立刻转发错误），然后发射一次包含所有源结果的数组。我们只需要把这个数组忽略，转换成Unit.Default就行：

using System.Reactive.Linq;
using System.Reactive.Unit;

// 假设obs1和obs2是你的两个IObservable<T>实例
IObservable<Unit> completedWhenBothDone = Observable.WhenAll(obs1, obs2)
                                                    .Select(_ => Unit.Default);

这个写法逻辑最清晰：明确表达「等两个都完成，然后发射一个Unit」，而且WhenAll本身只会发射一次值，完美匹配你要的类似ISingle<Unit>的效果（Rx.NET里没有ISingle这个单独类型，但只要确保Observable只发射一次就等价）。

方案二：用Merge+IgnoreElements+DefaultIfEmpty（更轻量化的信号合并） #

如果你想更贴近Reactor里then()忽略元素的思路，可以先把两个Observable的所有元素都忽略，只保留完成/错误信号，再合并它们，最后补一个Unit作为发射值：

IObservable<Unit> completedWhenBothDone = Observable.Merge(
                                                    obs1.IgnoreElements(),
                                                    obs2.IgnoreElements()
                                                )
                                                .DefaultIfEmpty(Unit.Default);

• IgnoreElements()：对应Reactor的then()，忽略源Observable的所有元素，只传递完成或错误通知；
• Merge()：把两个「只发完成信号」的Observable合并，只有当两个都完成时，合并后的Observable才会完成；
• DefaultIfEmpty(Unit.Default)：因为前面的Merge+IgnoreElements不会发射任何值，所以用这个操作符在完成前补一个Unit值，满足IObservable<Unit>的类型要求。

额外说明 #

如果你的需求只是「等两个都完成」，不需要发射任何值（只要Observable自己完成就行），那可以去掉Select或DefaultIfEmpty，直接用Observable.WhenAll(obs1, obs2)或者Observable.Merge(obs1.IgnoreElements(), obs2.IgnoreElements())就行——它们会在两个源都完成后自己进入完成状态，不会发射任何值。

另外要注意：不管用哪种方案，如果其中一个源Observable抛出错误，组合后的Observable都会立刻转发这个错误，不会等待另一个源完成，这和Reactor的行为是一致的。

内容的提问来源于stack exchange，提问作者jack