RxJS: Switching and Exhausting

ex5. RxJS: Switching and Exhausting.js

var source$ = Observable.timer(0, 200).take(6);

function multBy2Delayed(number) {
  // I take 1000ms to multiply your number by two
  return Observable.timer(1000).map(() => number * 2);
}

// NEW CODE STARTS HERE

var exhausted$ = source$.exhaustMap((number) => {
  return multBy2Delayed(number);
});

exhausted$.subscribe((number) => {
  console.log(number); // will log 0 and 10 to console
});