• 错误处理

    错误处理

    如果出现意外事件，我们可以在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()，这个事件不会真正触发。 因此，您应该记住在错误处理程序中包含一些调用，这将关闭应用程序中的任何可视加载状态。