Function collectTurnEvents

src/QueryEngine.test.ts:11–29

(
  stream: AsyncGenerator<QueryEngineReplEvent, TTerminal>,
)

import type { Tools } from './Tool.js'

async function collectTurnEvents<TTerminal>(
  stream: AsyncGenerator<QueryEngineReplEvent, TTerminal>,
): Promise<{
  events: QueryEngineReplEvent[]
  terminal: TTerminal
}> {
  const events: QueryEngineReplEvent[] = []

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

describe('QueryEngine prepared turn seams', () => {
  it('runPreparedTurn forwards the prepared params, events, and terminal value', async () => {