Function collectQuery

src/query.test.ts:161–179

(
  stream: AsyncGenerator<unknown, unknown>,
)

}

async function collectQuery(
  stream: AsyncGenerator<unknown, unknown>,
): Promise<{
  events: unknown[]
  terminal: unknown
}> {
  const events: unknown[] = []

  while (true) {
    const next = await stream.next()
    if (next.done) {
      return {
        events,
        terminal: next.value,
      }
    }
    events.push(next.value)
  }
}

function expectMetaUserMessage(events: unknown[], content: string) {
  const userMessage = (events as Array<Record<string, unknown>>).find(