重新理解 rxjs 的事件流

在做上一期 robust 的时候,受到这篇文章的启示,重新理解了 rxjs 的事件流这个概念。结合响应式编程范式的两个目标,对 rxjs 的理解又有了新的认识。

rxjs 是观察者模式、迭代器模式、函数式编程的结合体。其中,我一直对迭代器模式这个点不是很理解。在阅读上面那篇文章之后,我的思维豁然开朗了。在此之前,我只能强迫性的理解,new Observable 本质上是在决定什么时候进行迭代动作,也就是调用 next。但是,迭代器本身是怎么来的呢?我刚开始默认认为,迭代器需要用户自己构造。但在读完上面那篇文章之后,有了新的见解。rxjs 将一个对象的某个事件(例如 DOM 节点的 click 事件),在时间上的发生,抽象为一个虚拟的数组,它的示意图:

这个虚拟数组,和普通数组不一样,它不是在一开始就确定的,而是随着时间的流逝,不断往数组中新加元素,知道该对象被销毁,该数组也自动被销毁。而往数组中新增元素的过程,就是 next 被调用的时候。你可以想象成,这是一个无限个数坑位的列表,一个 click 发生,一个坑位就被填了,这个填坑位的过程,就是 next。而这个虚拟的数组,就是事件流的抽象表示。

既然是一个数组,那么就可以调用迭代器方法,rxjs 内置了非常多迭代器方法,比如常见的 map, filter, reduce。而 new Observable 本质上就是在构造这个迭代器数组。叫 Observable 很傻,还是叫 Stream 比较直观。