Class BatchTransform

Example

const batcher = new BatchTransform<"string">({
  lingerDurationMillis: 20,
  maxBatchRecords: 100,
  maxBatchBytes: 256 * 1024,
  match_seq_num: 0  // Optional: auto-increments per batch
});

// Pipe through the batcher and session to get acks
readable.pipeThrough(batcher).pipeThrough(session).pipeTo(writable);

// Or use manually
const writer = batcher.writable.getWriter();
writer.write(AppendRecord.make("foo"));
await writer.close();

for await (const batch of batcher.readable) {
  console.log(`Got batch of ${batch.records.length} records`);
}
Copy