obs-async-iterator.js

function createAsyncIterator() {
  const promises = [];
  const values = [];
  let done = false;
  let error = null;
  const subscription = this.subscribe({
    next(value) {
      if (promises.length > 0) {
        promises.shift().resolve({ value, done: false });
      } else {
        values.push(value);
      }
    },
    complete() {
      done = true;
      promises.splice(0).forEach(p => p.resolve({ done }));
    },
    error(err) {
      error = err;
      promises.splice(0).forEach(p => p.reject(err));
    }
  });
  return {
    next() {
      if (values.length > 0) {
        return { value: values.shift(), done: false };
      }
      if (done) {
        return { done };
      }
      if (error) {
        return Promise.reject(error);
      }
      return new Promise((resolve, reject) => {
        promises.push({ resolve, reject });
      });
    },
    return() {
      subscription.unsubscribe();
    }
  };
}