📅  最后修改于: 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');
没有调度程序,输出将如下所示-