Function collect

packages/ai-opencode/tests/translate.test.ts:32–41

(
  events: Array<OpencodeStreamEvent>,
  ctx: TranslateContext = makeCtx(),
)

}

async function collect(
  events: Array<OpencodeStreamEvent>,
  ctx: TranslateContext = makeCtx(),
): Promise<Array<StreamChunk>> {
  const chunks: Array<StreamChunk> = []
  for await (const chunk of translateOpencodeStream(fromArray(events), ctx)) {
    chunks.push(chunk)
  }
  return chunks
}

const session: OpencodeStreamEvent = { kind: 'session', sessionId: 'sess-1' }