来看看Rxjs

[MJingv]

《RxJS + Redux + React = Amazing!》的一个笔记

前端异步

• 用户交互（键盘、鼠标）
• Ajax
• 计时器／动画
• Web Sockets
• Web Workers

对于异步的控制

• Ajax取消／组合（组合的意思是，比如你发起了一个Ajax，然后你又发起了另外一个Ajax，后一个的发起用到了前一个的响应数据）
• Debounce／throttle／buffer等这些与时间相关的操作
• Drag and Drop
• Web Sockets, Web Workers, etc

异步解决方案 -- cb和promis

cb的特性

• 条件判断，然后决定是否进行下一个异步
• 你不想顺序执行这些异步
• 更加复杂的回调操作，比如你想并发它们等

promis的特性

• 被保证的未来（意思是，一旦你创建了一个Promise，那么它肯定会执行它要做的事情，你不能停止它）
• 不可变
• 单一的值（意思是，如果你监听一个Promise很多次，你只会得到相同的值，而不是执行多次请求 ）
• 缓存

Observable

• Observable是一个由零个、一个或多个值组成的流。
• Observable跨越了时间。
• Observable可以取消。

[MJingv]

RxJS（lodash for async）是Observable的一种引用实现

lodash的用法基本上就是，你给它一个输入，它给你一个输出。RxJS的用法则是，你给它一个输入，它给你一个输出，但是跨越了时间。

创建Observable有很多种方式

• 创建一个单值的Observable of('hello ')
• 从数组（或其他类型）创建一个Observable from([1,2,3])
• 设置时间间隔 interval(1000)
• 发起Ajax或WebSockets ajax('xxx') webSocket('ws://xxx')
• 事件 fromEvent（button,'click'）

Observable可以被订阅（Subscribing）

subscribe回调三个函数

• next （跨时间，可调用n次的promise成功then）
• error
• complete（是否完成）

rxjs操作符

• 对Observable进行转换：map、filter、reduce...
• 合并：concat、merge、zip
• 时间：debounce、throttle、buffer
• 懒：repeat/retry