Function collectStream

packages/tools/ai-codegen/src/PostProcess.ts:100–105

(stream: Stream.Stream<Uint8Array, any>)

  const spawner = yield* ChildProcessSpawner.ChildProcessSpawner

  const collectStream = (stream: Stream.Stream<Uint8Array, any>) =>
    stream.pipe(
      Stream.decodeText(),
      Stream.mkString,
      Effect.orElseSucceed(() => "")
    )

  const runCommand = Effect.fn("runCommand")(function*(
    command: string,