RxJS - การทำงานกับเครื่องมือจัดกำหนดการ

ตัวกำหนดตารางเวลาควบคุมการดำเนินการเมื่อการสมัครสมาชิกต้องเริ่มต้นและแจ้งเตือน

ในการใช้ตัวกำหนดตารางเวลาเราต้องการสิ่งต่อไปนี้ -

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

เอาต์พุต

หากไม่มีตัวกำหนดตารางเวลาผลลัพธ์จะเป็นดังที่แสดงด้านล่าง -