准备项目
我使用typescript来介绍rxjs. 因为我主要是在angular项目里面用ts....这部分可以理解为, 每当有人订阅这个Observable的时候, Observable会为他提供一个Observer.
在这里面, observer使用next方法对person进行推送....那么如何在error到达Observer之前对其进行拦截, 以便流可以继续走下去或者说这个流停止了,然后另外一个流替它继续走下去?...错误处理的Operators:
error() 被Observable在Observer上调用
catch() 在subscriber里并且在oserver得到它(错误)之前拦截错误,
retry(n)...表示取5个数, 也就是1,2,3,4,5.