11-Rxjs异步数据流编程-Rxjs快速入门教程

目前常见的异步编程的几种方法：
1、回调函数
2、事件监听/发布订阅
3、Promise
4、Rxjs

setInterval是一个实现定时调用的函数，可按照指定的周期(以毫秒计)来调用函数或计算表达式。

setInterval方法会不停地调用函数，直到 clearInterval被调用或窗口被关闭。

Rxjs

let stream = new Observable<number>(observer => {
let count = 0;
setInterval(() => {
observer.next(count++);
}, 1000);
});
stream.subscribe(value => console.log("Observable>"+value));

从上面列子可以看到 RxJS 和 Promise 的基本用法非常类似，除了一些关键词不同。Promise

里面用的是 then() 和 resolve()，而 RxJS 里面用的是 next() 和 subscribe()。