Function drainStream

apps/sim/lib/copilot/request/lifecycle/start.test.ts:116–122

(stream: ReadableStream)

import { createSSEStream } from './start'

async function drainStream(stream: ReadableStream) {
  const reader = stream.getReader()
  while (true) {
    const { done } = await reader.read()
    if (done) break
  }
}

describe('createSSEStream terminal error handling', () => {
  beforeEach(() => {