RxJS - Utility Operator subscribeOn

Questo operatore aiuta a sottoscrivere in modo asincrono la fonte Observable in base allo scheduler preso come input.

Sintassi

subscribeOn(scheduler): Observable

Parametri

scheduler - Lo scheduler viene utilizzato come input che aiuterà a riemettere le notifiche dalla sorgente osservabile.

Valore di ritorno

Restituirà un osservabile uguale all'osservabile sorgente, ma con il parametro dello scheduler.

Esempio

import { of, merge, asyncScheduler } from 'rxjs';
import { subscribeOn } from 'rxjs/operators';

let test1 = of(2, 4, 6, 8).pipe(subscribeOn(asyncScheduler));
let test2 = of(3, 6, 9, 12, 15);
let sub1 = merge(test1, test2).subscribe(console.log);

Produzione