携手 Rxjs 源码探索之旅（一）：Observable

前言

学习一门技术，源码无疑是最佳的老师，尤其是对于 Rxjs 这样的复杂库，更是如此。透过源码，我们可以窥见其设计原理，从而更好地理解其 API 的调用机制。带着这样的认知，笔者抽空研读了 Rxjs 源码，并决定将其剖析心得分享出来，希望能够帮助更多开发者深入理解 Rxjs。

揭开 Observable 神秘面纱

Rxjs 的核心概念之一便是 Observable，它代表着一种数据流，可以随着时间的推移不断产生新的值。想要理解 Rxjs，首先必须从 Observable 入手。

在 Rxjs 源码中，Observable 被定义为一个类，位于 rxjs/internal/Observable.ts 文件中。这个类提供了各种方法，用于创建、操作和订阅 Observable。

创建 Observable

创建 Observable 有多种方式，最常见的方式是使用静态方法 of()。例如：

const observable = Rx.Observable.of(1, 2, 3);

这行代码创建了一个 Observable，并向其中推入三个值：1、2 和 3。

操作 Observable

Observable 提供了丰富的操作符，可以用来对数据流进行各种操作。例如，我们可以使用 map() 操作符将每个值映射成另一个值：

const observable = Rx.Observable.of(1, 2, 3)
  .map(x => x * 2);

这行代码将 Observable 中的每个值都乘以 2，并返回一个新的 Observable。

订阅 Observable

创建好 Observable 后，还需要订阅它才能接收数据。订阅 Observable 的方式有很多，最常见的是使用 subscribe() 方法。例如：

observable.subscribe(
  value => console.log(value),
  error => console.error(error),
  () => console.log('completed')
);

这行代码订阅了 Observable，并在接收到数据时打印出来。

Observable 的工作原理

Observable 的工作原理可以简单地为：它是一个值产生器，可以随着时间的推移不断产生新的值。这些值可以是任何类型，包括数字、字符串、对象等。Observable 通过一个称为订阅者的机制来传递值。订阅者是一个函数，它会在 Observable 产生新值时被调用。

结语

Observable 是 Rxjs 的核心概念之一，理解了 Observable 的工作原理，也就掌握了 Rxjs 的精髓。在接下来的文章中，我们将继续探索 Rxjs 源码，深入剖析其其他重要概念，敬请期待！