当没有RxJs的观察者时调用方法

Question

如何在所有观察者取消订阅主题时调用方法。

更新

const alphaStore = new BehaviourSubject(0);
observer1 = alphaStore.subscribe(console.log);
observer2 = alphaStore.subscribe(console.log);

当所有观察者都取消订阅时。我想要一个方法来调用。喜欢...

Observer1取消订阅

Observer2取消订阅

所有观察员都离开了

Answer 1

您可以创建一个自定义Observable，它将跟踪订阅计数。

下面是一个简单的例子：

let count = 0;

const tracked$ = new Observable(() => {
  count++;

  return ()=>{
    count--;
    if (count === 0) {
      console.log('I am empty');
    }
  };
})

然后将它与实际工作的Observable合并。为简单起见，让我们想象它只是一个计时器

// const tracked$ = ...

const data$ = Observable.timer(0, 5);

const result$ = data$
  .merge(tracked$)
  .take(5)
  .subscribe(value => console.log('v:', value));

在发出5个值后 - 它将记录I am empty。

下面是一个实例（有一些重写和两个订阅）：

https://observable-playground.github.io/gist/4a7415f3528aa125fb686204041138cb

注意：此代码使用rxjs-compat表示法，更容易阅读。上面链接的示例使用.pipe表示法，现在更常见。

希望这可以帮助。

Answer 2

您所描述的已经是finalize()运营商。更好地说，finalize()在链处理时调用它的回调，这意味着当所有观察者取消订阅，链完成或错误时调用它。

const subject = new Subject();
const shared = subject.pipe(
  finalize(() => console.log('finalize')),
  share(),
);

https://stackblitz.com/edit/rxjs-rebfba

当所有观察员取消订阅share()取消订阅其来源触发finalize()。

目前没有办法区分为什么调用finalize()。请参阅此问题https://github.com/ReactiveX/rxjs/issues/2823以及有关如何执行此操作的示例。