import { from } from 'rxjs';
import { observeOn } from 'rxjs/operators';
import { asyncScheduler } from 'rxjs';
const source$ = from([1, 2, 3]);
const async$ = source$.pipe(
observeOn(asyncScheduler) // Emit values on the async scheduler
);
async$.subscribe(
value => console.log(value), // Output: 1, 2, 3
err => console.error(err),
() => console.log('Complete')
);