);
        if (readable.push(value))
          continue;
        reading = !1;
      } catch (err) {
        readable.destroy(err);
      }
      break;
    }
  }
  async function changeToAsyncValues(value) {
    isAsyncValues = !0;
    try {
      let res = await value;
      if (res === null)
        throw reading = !1, @makeErrorWithCode(229);
      if (readable.push(res)) {
        nextSyncWithAsyncValues();
        return;
      }
      reading = !1;
    } catch (err) {
      readable.destroy(err);
    }
  }
  async function nextSyncWithAsyncValues() {
    for (;; ) {
      try {
        let { value, done } = iterator.next();
        if (done) {
          readable.push(null);
          return;
        }
        let res = value && typeof value.then === "function" ? await value : value;
        if (res === null)
          throw reading = !1, @makeErrorWithCode(229);
        if (readable.push(res))
          continue;
        reading = !1;
      } catch (err) {
        readable.destroy(err);
      }
      break;
    }
  }
  async function nextAsync() {
    for (;; ) {
      try {
        let { value, done } = await iterator.next();
        if (done) {
          readable.push(null);
          return;
        }
        if (value === null)
          throw reading = !1, @makeErrorWithCode(229);
        if (readable.push(value))
          continue;
        reading = !1;
      } catch (err) {
        readable.destroy(err);
      }
      break;
    }
  }
  return readable;
}
$ = from;
return $})