当用户调用 API 时，构建 observables 数组，并在所有解析时执行块

Question

我想在用户与页面交互时构建一个可观察对象列表。每个 observable 都是单独订阅的，但我希望在进行单个或多个并发 API 调用后调用另一个函数。

我让每个函数都将一个 observable 推送到一个数组，并且我在我的 ngOnInit 中有一个 forkJoin 和对数组的订阅，但这只会触发一次。如何进行实时订阅，在所有当前 API 调用返回后执行回调函数，并在用户继续进行 API 调用时继续这样做？

例如，用户单击“创建事物”，然后什么也不做。

forkJoin(thingsInProgress).subscribe(() => doStuffWhenAllResolve())

...

createThing() {
    const = this.thingService.createThing().pipe(tap(() => doStuff()));
    thingsInProgress.push(createThing$);
    createThing$.subscribe();
}

deleteThing() {
    ...
}

updateThing() {
    ...
}

我想让doStuff() 开火，然后doStuffWhenAllResolve() 开火。或者，如果用户在几毫秒内依次单击“创建事物”、“删除事物”、“更新事物”，则 doStuff()（例如）被调用一次，doStuffWhenAllResolve() 被调用一次。

然后，如果用户真的很快又创建了 10 个东西，那么在所有重叠的 API 调用返回后，doStuffWhenAllResolve() 会再次被调用。

我在这里寻找什么 RXJS 运算符？

Answer 1

我会创建一个BehaviorSubject，其中createThing()、deleteThing() 和updateThing() 分别发射并与debounceTime 耦合。

类似这样的：

actionMade$ = new BehaviourSubject(new Date());

this.actionMade$.pipe(
  debounceTime(100), // Up to you to play with this 100, basically how long in ms does it have 
                     // to wait before accepting a new actionMade$
  switchMap(() => forkJoin(thingsInProgress)),
).subscribe(() => doStuffWhenAllResolve());

createThing() {
  ...
  this.actionMade$.next(new Date());
}

deleteThing() {
  ...
  this.actionMade$.next(new Date());
}

updateThing() {
  ...
  this.actionMade$.next(new Date());
}

ngOnDestroy() {
  this.actionMade$.complete();
}

================================================ ===== 请务必取消订阅（使用 sub.unsubscribe 或 takeUntil），否则它们会导致内存泄漏。