Function collectStream

src/query/stopHooks.test.ts:104–116

(
  stream: AsyncGenerator<unknown, T>,
)

}

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

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

beforeEach(() => {
  stopHookResults.length = 0