1、为什么要用 Rxjs
Promises欠缺如下能力：
不能生产多个值
不能重试
不能真正地玩转其它异步思想
// Observeable
let stream$ = Rx.Observable.from([1,2,3])
stream$.subscribe( (value) => {
console.log('Value',value);
})
// Promise
let promise = new Promise((resolve, reject) => {
setTimeout(()=> {
resolve( [1,2,3] )
})
})
promise.then((value) => {
console.log('Value',data)
})
