准备项目
我使用typescript来介绍rxjs. 因为我主要是在angular项目里面用ts....错误处理的Operators:
error() 被Observable在Observer上调用
catch() 在subscriber里并且在oserver得到它(错误)之前拦截错误,
retry(n)...subscribeToNumbers('Nick');
setTimeout(anotherSubscription, 2500);
这里interval是每隔1秒产生一个数据, take(5)表示取5个数, 也就是1,2,3,4,5...observable 所发出的值
const example = source.switchMap(() => Rx.Observable.interval(500));
// 输出: 0,1,2,3,4,5,6,7,8,9......0,1,2,3,4,5,6,7,8
const subscribe = example.subscribe(val => console.log(val));
更好的例子是: 网速比较慢的时候,