有没有办法检查源是否被订阅？

Question

正如标题所说，在 Angular 2 中，有没有办法检查源是否已经订阅？因为我必须在使用前检查它

this.subscription.unsubscribe();

这是我的代码：

this.Source = Rx.Observable.timer(startTime, 60000).timeInterval().pluck('interval');

this.Subscription = this.Source
  .subscribe(data => { something }

然后我想确保在调用之前它已被订阅 unsubscribe()

Answer 1

我有一个类似的案例，我有一个 if 条件和一个可选订阅：

if (languageIsSet) {
   // do things...
} else {
   this.langSub = this.langService.subscribe(lang => { 
      // do things...
   });
}

如果你想安全地调用取消订阅（你不知道是否已订阅），只需使用 EMPTY 实例初始化订阅即可：

private langSub: Subscription = Subscription.EMPTY;

现在您可以毫无错误地取消订阅。

Answer 2

看来您可以检查订阅是否已关闭

this.subscription.closed

指示此订阅是否已取消订阅。

Answer 3

您可以检查是否Subject有观察者，因为它具有公共财产observers。

对于Observables 你不能，因为它们通常没有观察者数组。例如，仅当您通过运营商对它们进行多播时Subject。multicast()

也许如果你能更详细地描述你的用例，我就能给你更好的建议。

const source = ...;
let subscribed = false;

Rx.Observable.defer(() => {
    subscribed = true;
    return source.finally(() => { subscribed = false });
})