RxJS - SubscribeOn del operador de servicios públicos

Este operador ayuda a suscripciones asincrónicas a la fuente Observable en función del planificador tomado como entrada.

Sintaxis

subscribeOn(scheduler): Observable

Parámetros

scheduler - El planificador se utiliza como entrada que ayudará a volver a emitir las notificaciones de la fuente observable.

Valor devuelto

Devolverá un observable igual que el observable de origen, pero con el parámetro del programador.

Ejemplo

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

Salida