序言：为什么要手写 RxJS ​

响应式编程的魅力 ​

在现代前端开发中，我们面临着越来越复杂的异步场景：用户交互事件、网络请求、WebSocket 消息、定时器……这些异步数据流交织在一起，传统的回调函数和 Promise 往往显得力不从心。

RxJS（Reactive Extensions for JavaScript）提供了一种优雅的解决方案：将一切异步操作统一抽象为 Observable 数据流，并通过丰富的操作符对其进行组合、变换和处理。这种响应式编程范式，已经成为 Angular 的核心基础，也被越来越多的 React 和 Vue 项目所采用。

为什么要从零实现 ​

你可能会问：RxJS 已经如此成熟，我直接学习使用不就好了吗？

这是一个好问题。事实上，能够熟练使用 RxJS 的开发者很多，但真正理解其内部原理的人却很少。这种"知其然不知其所以然"的状态，会在以下场景暴露问题：

• 遇到复杂的操作符组合时，不知道数据是如何流动的
• 出现内存泄漏时，不理解订阅与取消订阅的底层机制
• 需要自定义操作符时，不知道从何下手
• 面对性能问题时，无法判断瓶颈在哪里

亲手实现一个 Mini-RxJS，是突破这些困境的最佳途径。

当你从零构建 Observable、实现 pipe 机制、编写各类操作符时，你会深刻理解：

• Observable 为什么是惰性的：只有订阅时才会执行
• 操作符为什么是纯函数：返回新的 Observable 而非修改原有的
• Subject 如何实现多播：一个生产者对应多个消费者
• Scheduler 如何控制时序：微任务、宏任务、动画帧的调度差异

本书的目标读者 ​

本书面向具有以下背景的读者：

• 3年以上前端开发经验，熟悉 JavaScript/TypeScript
• 了解 RxJS 基本用法，使用过 Observable 和常见操作符
• 渴望深入理解原理，而非停留在 API 调用层面
• 有志于成为技术专家，能够设计和实现复杂的异步流程

如果你对 RxJS 完全陌生，建议先阅读官方文档或入门教程，建立基本认知后再来阅读本书。

本书的结构设计 ​

全书分为 17 个部分，遵循"概念 → 实现 → 应用"的学习路径：

第一部分：基础概念

• 响应式编程思想、Push/Pull 模型、观察者模式

第二至四部分：核心三件套

• Observable、Observer、Subscription 的完整实现

第五至十二部分：操作符实现

• 创建操作符、转换操作符、过滤操作符
• 组合操作符、高阶 Observable、错误处理、工具操作符

第十三至十四部分：高级特性

• Subject 家族、Scheduler 调度器

第十五至十七部分：实战与工程化

• Marble 测试、实战应用、TypeScript 类型、npm 发布

技术标准与参考 ​

本书的实现参考以下标准和资料：

• RxJS 7.x 源码：核心实现逻辑的主要参考
• ReactiveX 规范：Observable 契约的标准定义
• TC39 Observable 提案：JavaScript 原生 Observable 的未来方向

所有代码示例使用 TypeScript 编写，配合 Vitest 测试框架，确保实现的正确性和可验证性。

学习建议 ​

1. 动手实践：每个章节的代码务必亲手敲一遍，不要复制粘贴
2. 画 Marble 图：遇到复杂操作符时，画出数据流的时序图
3. 对比源码：实现后与 RxJS 官方源码对比，理解差异
4. 构建项目：最终将所有实现整合为可发布的 npm 包

开始这段旅程 ​

响应式编程是一种思维方式的转变。当你完成本书的学习，你不仅会掌握 RxJS 的内部原理，更会获得一种全新的视角来看待异步编程问题。

让我们从第一行代码开始，一起揭开 RxJS 的神秘面纱。

准备好了吗？让我们开始吧！