medium-rxjs-scheduler

medium-rxjs-scheduler.js

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

// "asyncScheduler" is a type of Scheduler which executes the Observable Asynchronously.
// "observeOn" is a Pipeable Operator that help us to re-emit the data with Scheduler. 

const observable = new Observable((observer) => {
  observer.next("First Data");
  observer.next("Second Data");
  observer.next("Third Data");
}).pipe(
  observeOn(asyncScheduler)
);
 
console.log('just before subscribe');

// Since we are using "asyncScheduler", This code will be executed asynchronously.
observable.subscribe({
  next(data) {
    console.log(data)
  }
});

console.log('just after subscribe');

// CONSOLE OUTPUT
// > just before subscribe
// > just after subscribe
// > First Data
// > Second Data
// > Third Data