• 处理订阅和释放资源

    处理订阅和释放资源

    在某些情况下，我们可能需要取消订阅Observable流。这是非常简单的，因为.subscribe()调用返回一个数据类型，我们可以调用unsubscribe()。

    1. export class MyApp {
    3.   private data: Observable<Array<string>>;
    4.   private value: string;
    5.   private subscribed: boolean;
    6.   private status: string;
    8.     init() {
    10.         this.data = new Observable(observer => {
    11.             let timeoutId = setTimeout(() => {
    12.                 observer.next('You will never see this message');
    13.             }, 2000);
    15.             this.status = 'Started';
    17.             return onUnsubscribe = () => {
    18.                 this.subscribed = false;
    19.                 this.status = 'Finished';
    20.                 clearTimeout(timeoutId);
    21.             }
    22.         });
    24.         let subscription = this.data.subscribe(
    25.             value => this.value = value,
    26.             error => console.log(error),
    27.             () => this.status = 'Finished';
    28.         );
    29.         this.subscribed = true;
    31.         setTimeout(() => {
    32.           subscription.unsubscribe();
    33.         }, 1000);
    34.     }
    36. }

    调用.unsubscribe（）将取消一个成员的回调监听Observable流。 当创建Observable时，您还可以返回自定义回调onUnsubscribe，当收听流的成员取消订阅时将调用该回调。 这对于必须实现的任何类型的清理都很有用。 如果我们没有清除setTimeout，那么值仍然会发射，但是没有人听。 为了节省资源，我们应该停止发射值。 一个重要的事情要注意的是，当您调用.unsubscribe（）时，您正在销毁正在侦听的订阅对象，因此附加到该订阅对象的完成事件将不会被调用。
    在大多数情况下，我们不需要显式调用unsubscribe方法，除非我们想提前取消或我们的Observable的生命周期比我们的订阅更长。 Observable运算符的默认行为是在发布.complete（）或.error（）消息后立即处理订阅。 请记住，RxJS的设计是在大多数时候以“发射和忘记”的方式使用。