.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>订阅，互不影响。
❓
延伸问答
IObservable<T>和IObserver<T>的主要功能是什么？
IObservable<T>用于推送数据，而IObserver<T>用于接收数据。
如何通过Subscribe方法连接IObservable和IObserver？
IObserver<T>通过Subscribe方法订阅IObservable<T>，从而开始接收数据流。
IObserver<T>需要实现哪些方法？
IObserver<T>需要实现OnNext、OnError和OnCompleted三个方法。
为什么Subscribe方法返回IDisposable？
Subscribe方法返回IDisposable，允许订阅者在不需要数据流时取消订阅，以释放资源。
一个IObservable<T>可以被多少个IObserver<T>订阅？
一个IObservable<T>可以被多个IObserver<T>订阅，互不影响。
IObservable<T>和IObserver<T>的交互流程是怎样的？
IObserver通过Subscribe方法订阅IObservable，IObservable调用OnNext推送数据，发生错误时调用OnError，正常结束时调用OnCompleted。
➡️
