RxJS - Observación del operador de servicios públicos

Este operador basado en el programador de entrada reemitirá las notificaciones de la fuente Observable.

Sintaxis

observeOn(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 { interval } from 'rxjs';
import { observeOn } from 'rxjs/operators';
import { animationFrameScheduler } from 'rxjs';

let testDiv = document.getElementById("test");
const intervals = interval(100);
let case1 = intervals.pipe(
   observeOn(animationFrameScheduler),
);
let sub1 = case1.subscribe(val => {
   console.log(val);
   testDiv.style.height = val + 'px';
   testDiv.style.width = val + 'px';
});

Salida