准备项目
我使用typescript来介绍rxjs. 因为我主要是在angular项目里面用ts....运行该文件:
RxJS Operator(操作符)
Operator是一个function, 它有一个输入, 还有一个输出....例 debounceTime (恢复时间):
如果该元素后10毫秒内, 没有出现其它元素, 那么该元素就可以通过.
例 reduce:
这个也和数组的reduce是一个意思....错误处理
Observable是会发生错误的, 如果错误被发送到了Observer的话, 整个流就结束了.
但是做Reactive编程的话, 有一个原则: Reactive的程序应该很有弹性/韧性....也就是说, 即使错误发生了, 程序也应该继续运行.
但是如果error function在Observer被调用了的话, 那就太晚了, 这样流就停止了.