例如 filter:
filter就是按条件过滤, 只让合格的元素通过.
例 debounceTime (恢复时间):
如果该元素后10毫秒内, 没有出现其它元素, 那么该元素就可以通过....结果如下:
用现实世界中炼钢生产流程的例子来解释使用Operator来进行Reactive数据流处理的过程:
原料(矿石)整个过程中会经过很多个工作站, 这里每个工作站都可以看作是RxJS的operator...每个工作站(operator)都是可以被组合使用的, 所以可以再加几个工作站也行.
错误处理
Observable是会发生错误的, 如果错误被发送到了Observer的话, 整个流就结束了....: 网速比较慢的时候, 客户端发送了多次重复的请求, 如果前一次请求在2秒内没有返回的话, 那么就取消前一次请求, 不再需要前一次请求的结果了, 这里就应该使用debounceTime配合switchMap...多个输入的observable的值, 按顺序, 按索引进行合并, 如果某一个observable在该索引上的值还没有发射值, 那么会等它, 直到所有的输入observables在该索引位置上的值都发射出来