RxJS - Operatore di trasformazione si espande

L'operatore di espansione assume una funzione come argomento che viene applicato sulla sorgente osservabile ricorsivamente e anche sull'output osservabile. Il valore finale è un osservabile.

Sintassi

expand(recursive_func:observable): Observable

Parametri

recursive_func - Una funzione viene applicata a tutti i valori provenienti dalla sorgente e restituisce un Observable.

Valore di ritorno

Un osservabile, con valori in base al risultato di recursive_func.

Esempio

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

Produzione