AsyncIterators RxJS

test.js

const ticker = interval(1000).pipe(take(100));

function snooze(ms) {
  return new Promise(resolve => setTimeout(snooze, ms));
}

async function* values() {
  for await (const number of ticker) {
    await snooze(2000);
    yield number;
  }
}

from(values()).subscribe(x => console.log(x));