无法退订 ReplaySubject 的订阅

Question

我已订阅 ReplaySubject 并尝试在 ngOnDestroy 方法中取消订阅。当我离开订阅组件并返回到同一个组件而不发出数据时，它再次被订阅。请问我该如何解决这个问题？

Shared.service.ts

import { Injectable } from '@angular/core';
import { TestCase } from './test-case-form/test-case.model';
import { Subject } from 'rxjs/Subject';
import { ReplaySubject } from 'rxjs/ReplaySubject';


@Injectable({
providedIn: 'root'
})
export class SharedService {
testCasesChanged = new Subject<TestCase[]>();
private startedEditing = new ReplaySubject<number>();
public startedEditing$ = this.startedEditing.asObservable();

setData(index) {
console.log("setData called", index);
this.startedEditing.next(index);
}
}

a.component.ts

export class TestFormComponent implements OnInit, OnDestroy {
@ViewChild('f') testForm : NgForm;
subscription: Subscription;
editIndex: number;
editMode = false;
editedTestCase: TestCase;

private testCases: TestCase[]= [];

ngOnInit() {
this.subscription = this.sharedService.startedEditing$
.subscribe((index: number) => {
console.log("Subscribed");
this.editIndex = index;
this.editMode = true;
this.editedTestCase = 
this.sharedService.getTestCase(this.editIndex);
}
ngOnDestroy() {
this.subscription.unsubscribe();
}

Answer 1

您在ngOnDestroy 中的退订有效。

您在组件中获取旧值，因为您使用的是ReplaySubject。 ReplaySubject 缓存所有随它发出的值。因此，每次您订阅该主题时，您的 subscribe 方法都会针对您通过此 ReplaySubject 发出的每个值调用。

可以通过以下方式更改缓冲区大小：

// Only the last emitted value is cached and emitted to every new subscriptions
private startedEditing = new ReplaySubject<number>(1); 

如果您只想获取最后发出的值，也可以使用BehaviourSubject。

但我猜你只是想使用一个简单的Subject。

Answer 2

private startedEditing = new ReplaySubject<number>();

public startedEditing$ = this.startedEditing.asObservable(); 
// `startedEditing$` is no longer `startedEditing` they are now two different things

那么你做

this.startedEditing.next(index);

仅更新startedEditing

startedEditing$ 永远不会在您提供的代码中更新。你能简化并只使用一个吗？