RxJS - SubscribeOn do operador de serviços públicos

Este operador ajuda a assinantes assíncronos para a fonte Observable com base no planejador considerado como entrada.

Sintaxe

subscribeOn(scheduler): Observable

Parâmetros

scheduler - O planejador é usado como uma entrada que ajudará a reemitir as notificações da fonte observável.

Valor de retorno

Ele retornará um observável igual ao observável de origem, mas com o parâmetro do planejador.

Exemplo

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

Resultado