📜  RxJS-使用调度程序

📅  最后修改于: 2020-10-20 05:36:55             🧑  作者: Mango


调度程序控制何时必须启动和通知订阅的执行。

要使用调度程序,我们需要以下内容-

import { Observable, asyncScheduler } from 'rxjs';
import { observeOn } from 'rxjs/operators';

这是一个工作示例,其中,我们将使用调度程序来决定执行情况。

import { Observable, asyncScheduler } from 'rxjs';
import { observeOn } from 'rxjs/operators';

var observable = new Observable(function subscribe(subscriber) {
   subscriber.next("My First Observable");
   subscriber.next("Testing Observable");
   subscriber.complete();
}).pipe(
   observeOn(asyncScheduler)
);
console.log("Observable Created");
observable.subscribe(
   x => console.log(x),
   (e)=>console.log(e),
   ()=>console.log("Observable is complete")
);

console.log('Observable Subscribed');

输出

排程器

没有调度程序,输出将如下所示-

调度程序控件