system.reactive - Rx 自动分离行为，它有什么用？它是如何工作的？

Question

Rx 提供 Observable.Create 和 Observer.Create 工厂方法，它们具有自动分离行为。

它有什么用？它是如何工作的？

Answer 1

Rx 将在您第一次调用observer.OnCompleted()或observer.OnError()取消订阅时自动分离观察者。这保证了 Rx 语法（观察者在收到 Completed 或 Error 事件或取消订阅后将什么也看不到），即使您的自定义 observable 是流氓并尝试发送多个错误或完成。