.NET 响应式编程System.Reactive系列文章（二）：深入理解IObservable和IObserver
💡
原文中文，约3900字，阅读约需10分钟。
📝
内容提要
本文介绍了System.Reactive中的IObservable<T>和IObserver<T>接口，强调这两个接口是掌握Rx的基础。IObservable<T>用于推送数据，IObserver<T>用于接收数据，二者通过Subscribe方法连接。文章还提供了简单的代码示例，展示了它们的交互流程和使用方式。
🎯
关键要点
- 本文介绍了System.Reactive中的IObservable<T>和IObserver<T>接口。
- IObservable<T>用于推送数据，IObserver<T>用于接收数据。
- 二者通过Subscribe方法连接，理解这两个接口是掌握Rx的基础。
- IObservable<T>是数据流的生产者，IObserver<T>是数据流的消费者。
- IObservable<T>的职责是代表一个数据流，产生零个、一个或多个数据项。
- IObserver<T>的职责是对IObservable<T>提供的数据流做出响应。
- IObserver<T>需要实现三个方法：OnNext、OnError和OnCompleted。
- 通过Subscribe方法，观察者订阅可观察对象，数据流开始传递。
- 示例代码展示了如何实现自定义的IObservable和IObserver。
- Subscribe方法返回IDisposable，允许取消订阅以释放资源。
- 一个IObservable<T>可以被多个IObserver<T>订阅，互不影响。
➡️
