Subscription - 订阅

什么是一个 Subscription？Subscription 是一个代表可清理资源的对象，通常是一个 Observable 的执行。Subscription 有一个重要的方法unsubscribe，它不需要任何参数，只是处理 Subscription 拥有的资源。在之前的 RxJS 版本，Subscription 被称为‘可清理对象’。

import { interval } from "rxjs";

const observable = interval(1000);
const subscription = observable.subscribe((x) => console.log(x));
// Later:
// This cancels the ongoing Observable execution which
// was started by calling subscribe with an Observer.
subscription.unsubscribe();

一个 Subscription 实际上有一个unsubscribe()方法去释放资源或取消 Observable 的执行。

Subscriptions 也可以放到一起，因此一个 Subscription 的unsubscribe()调用可以取消订阅多个 Subscriptions。你可以添加一个 Subscription 到另一个。

import { interval } from "rxjs";

const observable1 = interval(400);
const observable2 = interval(300);

const subscription = observable1.subscribe((x) => console.log("first: " + x));
const childSubscription = observable2.subscribe((x) =>
  console.log("second: " + x),
);

subscription.add(childSubscription);

setTimeout(() => {
  // Unsubscribes BOTH subscription and childSubscription
  subscription.unsubscribe();
}, 1000);

当执行时，我们可以看见以下输出；

second: 0
first: 0
second: 1
first: 1
second: 2

Subscriptions 也有一个remove(otherSubscription)方法，以便于撤销添加子 Subscription。