Categories: RxJS教程

RxJS：公用程序运算符observeOn

基于输入调度程序的该运算符将重新发送来自源Observable的通知。

句法

observeOn(scheduler): Observable

参量

scheduler – 有助于从可观察的源重新发送通知。

返回值

它将返回与源observable相同的observable，但具有调度程序参数。

例

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