前置知识点

1.响应式编程：使用异步数据流进行编程，适用于大量和数据相关的事件交互，特别是高实时性要求；
2.流：不间断按时间排序的序列；
（1）流产生三种不同类型事件—值/错误/完成的信号，对这三类定义事件处理函数，就可以异步捕获这些事件；
（2）每个流有多个方法，调用时基于原始流返回一个新的流，原来的流不做修改，保证不可变性；
3.观察者模式(发布-订阅模式)：流是被观察对象，某个函数订阅流的某个事件，该函数是观察者，当流的某个事件产生了，对应的函数就会执行；