准备项目
我使用typescript来介绍rxjs. 因为我主要是在angular项目里面用ts....可以在数据流的途中对值进行转换的操作符
Subject: 既包括Observable也包括Observer
Observable, Observer, Subscriber的角色关系:
工厂生产杂志, 邮递员去送杂志..., 就相当于是Observable, 邮递员给你带来了啥?...结果如下:
用现实世界中炼钢生产流程的例子来解释使用Operator来进行Reactive数据流处理的过程:
原料(矿石)整个过程中会经过很多个工作站, 这里每个工作站都可以看作是RxJS的operator...也就是说, 即使错误发生了, 程序也应该继续运行.
但是如果error function在Observer被调用了的话, 那就太晚了, 这样流就停止了.