Question du test Initiation à RxJS

Créer un opérateur personnalisé en RxJS

Difficile

L'exemple si dessous nous montre quelle pratique sous RxJS ?

const request = interval(1000);

function takeOnlyPairAndSum(
  max: number
): UnaryFunction<Observable<number>, Observable<number>> {
  return pipe(
    filter((val) => val % 2 == 0),
    reduce((acc, value) => acc + value),
    tap(x => console.log(x)),
  );
}

request.pipe(takeOnlyPairAndSum(10)).subscribe();
Auteur: Amine BouchamStatut : PubliéeQuestion passée 17 fois
Modifier
0
Évaluations de la communautéPersonne n'a encore évalué cette question, soyez le premier !