请说明在 .NET 环境中，Reactive Extensions（Rx.NET）的核心设计思想，并阐述它是如何用于处理异步数据流的？
考察说明
考察候选人是否理解 Rx.NET 的响应式编程范式，以及如何利用其抽象异步数据流。
回答思路
- 【回答框架 1】Rx.NET 是微软实现的响应式扩展库，基于可观察序列（IObservable）和观察者（IObserver）模式。它提供 LINQ 风格的查询操作符，允许以声明方式组合异步和基于事件的程序。
- 【回答框架 2】异步数据流通过 IObservable 接口实现，其作为数据生产端，可异步推送数据；IObserver 作为消费端，通过 OnNext、OnError、OnCompleted 方法响应数据。不同于 Task 的单个异步结果，Rx.NET 处理的是可观察的序列，可推送多个值。
- 【回答框架 3】Rx.NET 提供丰富的操作符如 Select、Where、Merge、CombineLatest 等，基于 LINQ 风格，支持对数据流的投影、过滤、合并和组合。通过调度器控制异步和并发行为。
- 【回答框架 4】处理异步数据流的关键是订阅操作符链：从源可观察序列开始，经过操作符变形，最终由观察者订阅。例如，从异步事件源创建 IObservable，用 Select、Where 处理，用 Subscribe 接收结果，实现响应式处理。
- 【回答框架 5】Rx.NET 常用于处理 UI 事件、实时数据流和复杂异步场景，提供取消订阅（IDisposable）和资源管理机制，避免内存泄漏。
- 【关键点 1】Rx.NET 基于 IObservable/IObserver 模式，是观察者模式的对称实现。
- 【关键点 2】处理异步数据流是通过操作符链组合，最终订阅。
- 【关键点 3】有大量操作符支持数据流变形，如 Select、Where、Merge。
- 【关键点 4】使用调度器管理并发和异步。
- 【关键点 5】强调可取消订阅和资源释放。
- 【易错点 1】混淆 IObservable 和 Task：Task 表示单个异步结果，而 IObservable 表示多个值的序列。
- 【易错点 2】忘记处理订阅的 IDisposable，导致内存泄漏。
- 【易错点 3】未考虑错误处理，OnError 未实现。