PersistentAI API Documentation / @persistent-ai/fireflow-types / pumpBatchedStreamToChannel

Function: pumpBatchedStreamToChannel()

pumpBatchedStreamToChannel<T>(batchedStream, channel): Promise<void>

Defined in: packages/fireflow-types/src/flow/execution/runtime/stream-bridge.ts:168

Pump all data from a batched async iterable into a MultiChannel. Same as pumpDBOSStreamToChannel but for batched sources like readStreamNonDurable() which returns AsyncIterable<T[]>.

Each batch is unpacked and items are sent individually to the channel.

Type Parameters

T

T

Parameters

batchedStream

AsyncIterable<T[]>

The batched async iterable (e.g. from readStreamNonDurable)

channel

MultiChannel<T>

The local MultiChannel to write to

Returns

Promise<void>