Subject.complete()是否取消订阅所有听众？

Question

我用这个方法构建了一个简单的确认对话服务(Angular 2):

confirm(body?: string, title?: string): Subject<void> {
    this.confirmation = new Subject<void>();
    // ... show dialog here... "are you sure?"
    return this.confirmation;
}

_onYesClicked() {
  // ... closing the dialog
  this.confirmation.next();
  this.confirmation.complete();
} 

_onNoClicked() {
  // ... closing the dialog
  this.confirmation.complete();
}

用法:

confirmationService.confirm().subscribe(() => alert("CONFIRMED"));

如果有人使用该服务,他会返回一个Subject(这是一个Observable),并且可以"订阅()".点击"是"时调用订阅,因此确认给出了...

这是正确的方法吗？更重要的是...将致电

this.confirmation.complete();

取消订阅订阅的侦听器,从而防止任何延迟引用(内存泄漏)？

Answer 1

如果你想确保删除所有Observers,你可以在https://github.com/ReactiveX/rxjs/blob/master/src/internal/Subject.ts#L91中自行检查.它调用complete()所有Observers(Observers通常只是实现Observer接口的哑对象)然后设置this.observers.length = 0;.所以答案是肯定的.

你的方法是有效的,它与Angular2经常使用的方法基本相同EventEmitter.你可以改进的一件事是asObservable()在暴露Subjects 时开始使用.这将隐藏您使用Subject底层并返回常规Observable 的事实.这样你就不会让你的用户偶然(或误解)试图打电话next(),complete()或者error()你的用户Subject.

关于内存泄漏,这必须由RxJS处理,因此您不必担心它,如果有问题,作者可能会在您之前注意到它.

另外看看这个:Observable vs Subject和asObservable