RxJS Implementation 是面向 Angular 项目的技能，用于实现 RxJS 响应式编程。
用途：创建和订阅 Observable，应用操作符处理数据流，修复内存泄漏，进行错误处理，创建 Subject，并构建响应式数据管道。
主要能力：
- Observable 基础：用 new Observable 创建，subscribe 订阅，unsubscribe 取消。
- 操作符：转换类（map、filter、switchMap、mergeMap、concatMap、exhaustMap）；过滤类（filter、first、take、takeUntil、distinct、debounceTime）；组合类（combineLatest、merge、concat、zip、withLatestFrom）。
- Subject 类型：Subject、BehaviorSubject（含初始值）、ReplaySubject（重放 N 个值），并可在服务中暴露 asObservable。
- 错误处理：catchError、retry、timeout。
- 防止内存泄漏：destroy$ 配合 takeUntil，或在模板中使用 async 管道。
- 进阶模式：shareReplay 缓存共享订阅、scan 累积状态、forkJoin 并行请求。
- 测试：使用 rxjs-marbles 的 marbles 进行弹珠测试。
使用方式：在 Angular 组件或服务中按上述模式编写代码，例如用 switchMap 替代嵌套订阅，用 takeUntil(this.destroy$) 并在 ngOnDestroy 中调用 destroy$.next() 和 destroy$.complete() 取消订阅。
适用场景：需要处理异步数据流、HTTP 请求合并或取消、状态累积、多请求并行加载等响应式场景。
限制：资料未提供具体安装命令、版本要求、性能数据或收费信息；示例基于 Angular 与 TypeScript 环境，需已具备相应依赖。