RxJS - Exploitant utilitaire s'abonner

Cet opérateur permet de s'abonner asynchrone à la source Observable en fonction de l'ordonnanceur pris en entrée.

Syntaxe

subscribeOn(scheduler): Observable

Paramètres

scheduler - Le planificateur est utilisé comme une entrée qui aidera à réémettre les notifications de l'observable source.

Valeur de retour

Il retournera une observable identique à l'observable source, mais avec le paramètre du planificateur.

Exemple

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

Production