Início / coding / Perguntas / 77134942
Accepted
LeO
Asked: 2023-09-19 21:21:48 +0800 CST

RxJS: exaustoMap em V8

  • 772

De acordo com o documento exhaustMaputiliza um ResultSelector e este será removido na V8. Tentei seguir o exemplo , mas não consegui entender como refatorar meu código.

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
    },
  });

Como adaptar o código para ficar pronto para V8?

rxjs

1 respostas

  1. Best Answer

    Como você não está usando o seletor de resultados (segundo argumento de exhaustMap), não há nada que você precise fazer em relação a isso para que este código seja compatível com V8.

    No seu exemplo você pode ver que a sugestão que eles fazem é substituir o segundo parâmetro do switchMappipe a mapno resultado:

    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)))
);

    Se verificarmos os documentos no exhaustMapoperador :

    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>

    O segundo argumento resultSelector?: (outerValue: T, innerValue: ObservedValueOf<O>, outerIndex: number, innerIndex: number) => Rserá removido, portanto não o utilize.

    Como o snippet que você colou não faz uso dele, não há nenhuma ação a ser tomada :)

    • 2

relate perguntas