Method fromReadableStream

out/cli.cjs:69127–69165

* Generates a Stream from a newline-separated ReadableStream * where each item is a JSON value.

(readableStream, controller)

      }
    }
    return new _Stream(iterator2, controller);
  }
  /**
   * Generates a Stream from a newline-separated ReadableStream
   * where each item is a JSON value.
   */
  static fromReadableStream(readableStream, controller) {
    let consumed = false;
    async function* iterLines() {
      const lineDecoder = new LineDecoder();
      const iter = readableStreamAsyncIterable(readableStream);
      for await (const chunk of iter) {
        for (const line of lineDecoder.decode(chunk)) {
          yield line;
        }
      }
      for (const line of lineDecoder.flush()) {
        yield line;
      }
    }
    async function* iterator2() {
      if (consumed) {
        throw new Error("Cannot iterate over a consumed stream, use `.tee()` to split the stream.");
      }
      consumed = true;
      let done = false;
      try {
        for await (const line of iterLines()) {
          if (done)
            continue;
          if (line)
            yield JSON.parse(line);
        }
        done = true;
      } catch (e3) {
        if (e3 instanceof Error && e3.name === "AbortError")
          return;
        throw e3;
      } finally {
        if (!done)
          controller.abort();
      }