主页 / coding / 问题 / 77134942
Accepted
LeO
Asked: 2023-09-19 21:21:48 +0800 CST

RxJS：V8中的exhaustMap

  • 772

根据文档，它exhaustMap使用 ResultSelector，这将在 V8 中删除。我尝试遵循该示例，但无法找到如何重构我的代码的线索。

interval(5000)
  .pipe(
    takeWhile(() => !this.isDialogDestroyed),
    exhaustMap(() => this.versService.checkStatus(myParameters))
  )
  .subscribe({
    next: (status) => {
      if (status === 'DONE') {
        this.isDialogDestroyed = true;
        // ...  further processing - removed for simplicity 
      }
    },
    error: () => {
      // Handle errors here
    },
  });

如何调整代码以适应 V8？

rxjs

1 个回答

  1. Best Answer

    因为您自己没有使用结果选择器（ 的第二个参数exhaustMap），所以您无需执行任何操作即可使该代码在 V8 中兼容。

    在您的示例中，您可以看到他们提出的建议是将结果中的第二个参数替换switchMap为管道 a ：map

    import { fromEvent, switchMap, interval, map } from 'rxjs';

// deprecated
fromEvent(document, 'click').pipe(
  switchMap((x) => interval(1000), (_, x) => x + 1)
);
// suggested change
fromEvent(document, 'click').pipe(
  switchMap((x) => interval(1000).pipe(map((x) => x + 1)))
);

    如果我们检查操作员的文档exhaustMap：

    function exhaustMap<T, R, O extends ObservableInput<any>>(project: (value: T, index: number) => O, resultSelector?: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R): OperatorFunction<T, ObservedValueOf<O> | R>

    第二个参数resultSelector?: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => R将被删除，因此不要使用它。

    由于您粘贴的代码片段没有使用它，因此您无需采取任何操作:)

    • 2

相关问题