Function streamOf

packages/ai/tests/stream-processor.test.ts:36–42

Create an async iterable from a list of chunks.

(
  ...chunks: Array<StreamChunk>
)

/** Create an async iterable from a list of chunks. */
async function* streamOf(
  ...chunks: Array<StreamChunk>
): AsyncIterable<StreamChunk> {
  for (const c of chunks) {
    yield c
  }
}

/** Shorthand for common event sequences. */
const ev = {