Function drainStream

src/testing/ptyContractHarness.ts:189–212

(
    stream: ReadableStream<Uint8Array>,
    onChunk: (chunk: string) => void,
  )

  }

  async function drainStream(
    stream: ReadableStream<Uint8Array>,
    onChunk: (chunk: string) => void,
  ): Promise<string> {
    const reader = stream.getReader()
    const decoder = new TextDecoder()
    let text = ''

    while (true) {
      const { done, value } = await reader.read()
      if (done) {
        const chunk = decoder.decode()
        if (chunk.length > 0) {
          text += chunk
          onChunk(chunk)
        }
        return text
      }

      const chunk = decoder.decode(value, { stream: true })
      text += chunk
      onChunk(chunk)
    }
  }

  function onText(chunk: string): void {
    rawText += chunk