obs-async-iterator.js

function createAsyncIterator() {
  const promises = [];
  this.subscribe({
    next(value) {
      promises.shift().resolve({ value, done: false });
    }
  });
  return {
    next() {
      return new Promise((resolve, reject) => {
        promises.push({ resolve, reject });
      });
    }
  };
}