主页 / 问题 / 958447
Accepted
Алексей
Asked:2020-03-19 17:26:54 +0800 CST2020-03-19 17:26:54 +0800 CST

等到上一个订阅结束

  • 772

订阅：

this.documentChange.asObservable().subscribe(value => {
  if (this.autosave) {
    value._id = this.documentId;
    this.updateDocument(value, change);
  }
});

它的工作原理是这样的：this.documentChange.next(value)之后，可以进行另一个操作 this.documentChange.next(value)。

问题：如何让最后一个操作等待上一个操作结束？

angular

1 个回答

  1. Best Answer

    有一个订阅......它的工作原理是这样的：this.documentChange.next(value)

    next这不是订阅的工作，而是事件的产生。

    以便最后一个操作等待上一个操作的结束

    没有所谓的“激活”😉，只需使用术语“事件”。

    我将假设updateDocument这是某种异步操作，并且您希望文档更新请求按顺序处理，而不是并行处理。

    为此，使用了运算符concatMap，它在后台创建了一个队列：

    this.documentChange.asObservable().pipe(
  filter(() => this.autosave),
  concatMap((value) => {
    value._id = this.documentId;
    return this.updateDocument(value, change);
  })
).subscribe(() => {
  console.log('Документ обновлен');
});

    此外，您没有任何线程取消订阅，这会在 Angular 尝试释放组件的资源时泄漏内存：

    private readonly destroy$ = new Subject<void>();

public ngOnDestroy(): void {
  this.destroy$.next();
  this.destroy$.complete();
}

    然后concatMap添加一个运算符takeUntil：

    takeUntil(this.destroy$)
    • 1

相关问题