Streaming von Datenströmen mit typisierten asynchronen Generatoren

interface DataBatch {
  readonly batchId: number;
  readonly items: string[];
}
 
async function* streamDataBatches(totalBatches: number): AsyncGenerator<DataBatch, void, unknown> {
  for (let i = 1; i <= totalBatches; i++) {
    await new Promise(resolve => setTimeout(resolve, 10));
    yield { batchId: i, items: [`item_${i}A`, `item_${i}B`] };
  }
}
 
async function processStream(): Promise<number> {
  let totalProcessed = 0;
  for await (const batch of streamDataBatches(3)) {
    totalProcessed += batch.items.length;
  }
  return totalProcessed;
}