错误处理

如果出现意外事件，我们可以在Observable流上引发一个错误，并在订阅例程中使用保留用于处理错误的函数来查看发生了什么。

  1. export class App {
  3.     values: number[] = [];
  4.     anyErrors: Error;
  5.     private data: Observable<number[]>;
  7.     constructor() {
  9.         this.data = new Observable(observer => {
  10.               setTimeout(() => {
  11.                 observer.next(10);
  12.             }, 1500);
  13.             setTimeout(() => {
  14.                 observer.error(new Error('Something bad happened!'));
  15.             }, 2000);
  16.             setTimeout(() => {
  17.                 observer.next(50);
  18.             }, 2500);
  19.         });
  21.         let subscription = this.data.subscribe(
  22.             value => this.values.push(value),
  23.             error => this.anyErrors = error
  24.         );
  25.     }
  26. }

这里出现一个错误并捕获。 需要注意的一点是，如果我们在引发错误后包含一个.complete()，这个事件不会真正触发。 因此，您应该记住在错误处理程序中包含一些调用，这将关闭应用程序中的任何可视加载状态。