Angular中rxjs的主题complete在完成时无法取消订阅
该问题可能是由于未正确取消订阅引起的。下面是一种可能的解决方法，它使用“takeUntil”操作符，确保在“complete”事件后取消订阅。
在组件代码中：
import { Component, OnDestroy } from '@angular/core'; import { Subject } from 'rxjs'; import { takeUntil } from 'rxjs/operators'; import { SomeService } from './some.service';
@Component({ selector: 'app-some-component', template: '
Some component
', }) export class SomeComponent implements OnDestroy { private unsubscribe$: Subjectconstructor(private someService: SomeService) {}
ngOnInit(): void { this.someService .getData() .pipe(takeUntil(this.unsubscribe$)) .subscribe((data) => { console.log(data); }); }
ngOnDestroy(): void { this.unsubscribe$.next(); this.unsubscribe$.complete(); } }
在服务代码中：
import { Injectable } from '@angular/core'; import { Observable } from 'rxjs';
@Injectable({
providedIn: 'root',
})
export class SomeService {
getData(): Observable
这个解决方案使用“takeUntil”操作符，它增加了一个辅助观察者（“unsubscribe$”对象），并在组件销毁时取消订阅。这可以确保不会出现内存泄漏，并且当观察到“complete”事件时会正确地取消订阅。