rxjs - 有没有一种方法可以进行一次订阅但两次回调(一个已消除？)

Question

我有:

thingie.valueChanges.pipe(
  takeUntil(this.destroy$)
).subscribe(() => doSomething());

thingie.valueChanges.pipe(
  takeUntil(this.destroy$),
  debouce(250),
  mergeMap((x) => forMergeMap(x))
).subscribe((x) => doSomethingWithX(x));

有没有办法将其合并到一个订阅中？

Answer 1

您可以简单地在tap中执行回调逻辑:

thingie.valueChanges.pipe(
  tap(() => doSomething()),
  debouce(250),
  mergeMap(x => forMergeMap(x)),
  tap(x => doSomethingWithX(x)),
  takeUntil(this.destroy$)
).subscribe();