Function byteStream

packages/effect/test/unstable/httpapi/HttpApiClient.test.ts:846–857

(chunks: ReadonlyArray<Uint8Array>)

}

const byteStream = (chunks: ReadonlyArray<Uint8Array>): ReadableStream<Uint8Array> => {
  let index = 0
  return new ReadableStream<Uint8Array>({
    pull(controller) {
      if (index === chunks.length) {
        controller.close()
      } else {
        controller.enqueue(chunks[index++]!)
      }
    }
  })
}