RxJS - Opérateur de transformation expand

L'opérateur d'expansion prend une fonction comme argument qui est appliqué sur l'observable source de manière récursive et également sur l'observable en sortie. La valeur finale est une observable.

Syntaxe

expand(recursive_func:observable): Observable

Paramètres

recursive_func - Une fonction est appliquée à toutes les valeurs provenant de la source et renvoie un Observable.

Valeur de retour

Un observable, avec des valeurs selon le résultat de recursive_func.

Exemple

import { of } from 'rxjs';
import { expand } from 'rxjs/operators';

let buffered_array = of(2).pipe(expand(x => of(2 * x)));
buffered_array.subscribe(arr => console.log(arr));

Production