Subscription (订阅)

什么是 Subscription ？ - Subscription 是表示可清理资源的对象，通常是 Observable 的执行。Subscription 有一个重要的方法，即 unsubscribe，它不需要任何参数，只是用来清理由 Subscription 占用的资源。在上一个版本的 RxJS 中，Subscription 叫做 “Disposable” (可清理对象)。

  1. var observable = Rx.Observable.interval(1000);
  2. var subscription = observable.subscribe(x => console.log(x));
  3. // 稍后：
  4. // 这会取消正在进行中的 Observable 执行
  5. // Observable 执行是通过使用观察者调用 subscribe 方法启动的
  6. subscription.unsubscribe();

Subscription 基本上只有一个 unsubscribe() 函数，这个函数用来释放资源或去取消 Observable 执行。

Subscription 还可以合在一起，这样一个 Subscription 调用 unsubscribe() 方法，可能会有多个 Subscription 取消订阅 。你可以通过把一个 Subscription 添加到另一个上面来做这件事：

  1. var observable1 = Rx.Observable.interval(400);
  2. var observable2 = Rx.Observable.interval(300);
  4. var subscription = observable1.subscribe(x => console.log('first: ' + x));
  5. var childSubscription = observable2.subscribe(x => console.log('second: ' + x));
  7. subscription.add(childSubscription);
  9. setTimeout(() => {
  10.   // subscription 和 childSubscription 都会取消订阅
  11.   subscription.unsubscribe();
  12. }, 1000);

执行时，我们在控制台中看到：

  1. second: 0
  2. first: 0
  3. second: 1
  4. first: 1
  5. second: 2

Subscriptions 还有一个 remove(otherSubscription) 方法，用来撤销一个已添加的子 Subscription 。