reactive-programming

用途

该技能用于实现响应式编程模式，借助 RxJS、流（streams）、可观察对象（Observables）和背压（backpressure）处理，构建能够响应异步数据流的应用。

适用时机

根据资料，适合在以下情况使用：

• 复杂的异步数据流
• 实时数据更新
• 事件驱动架构
• UI 状态管理
• WebSocket/SSE 处理
• 组合多个数据源

快速开始

资料给出一个最小可用示例，从 rxjs 引入 Observable、Subject、BehaviorSubject、fromEvent、interval，并从 rxjs/operators 引入 map、filter、debounceTime、distinctUntilChanged、switchMap，随后从数组创建可观察对象并订阅：

import {
  Observable,
  Subject,
  BehaviorSubject,
  fromEvent,
  interval,
} from "rxjs";
import {
  map,
  filter,
  debounceTime,
  distinctUntilChanged,
  switchMap,
} from "rxjs/operators";

// Create observable from array
const numbers$ = new Observable<number>((subscriber) => {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  subscriber.complete();
});

numbers$.subscribe({
  next: (value) => console.log(value),

资料注明完整实现参见参考指南。

参考指南

详细实现位于 references/ 目录，包含以下指南：

• RxJS 基础（RxJS Basics）
• 防抖搜索（Search with Debounce）
• 状态管理（State Management）
• 带重连的 WebSocket（WebSocket with Reconnection）
• 组合多个流（Combining Multiple Streams）
• 背压处理（Backpressure Handling）
• 自定义操作符（Custom Operators）

最佳实践

建议做法（✅ DO）：

• 取消订阅以防止内存泄漏
• 使用操作符转换数据
• 正确处理错误
• 对昂贵操作使用 shareReplay
• 在需要时组合流
• 测试响应式代码

应避免做法（❌ DON'T）：

• 对同一可观察对象多次订阅
• 忘记取消订阅
• 使用嵌套订阅
• 忽略错误处理
• 使可观察对象有状态

限制

资料未提供该技能的安装命令、价格、支持的框架版本或具体运行环境要求，这些信息暂未提供。