RxJS - Làm việc với Trình lập lịch

Bộ lập lịch kiểm soát việc thực hiện khi đăng ký phải bắt đầu và được thông báo.

Để sử dụng công cụ lập lịch, chúng ta cần những điều sau:

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

Đây là một ví dụ hoạt động, trong đó, chúng tôi sẽ sử dụng bộ lập lịch để quyết định việc thực thi.

Thí dụ

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

Đầu ra

Nếu không có bộ lập lịch, kết quả đầu ra sẽ như hình dưới đây -