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

Interface: INonDurableStreamReader

Defined in: packages/fireflow-types/src/execution/services/dbos-types.ts:294

Abstract stream reader interface for non-durable stream reading.

Implementations use EventBus/StreamBridge under the hood.

Properties

subscribeToStream()

subscribeToStream: <T>(workflowId, streamKey, fromOffset?, batchConfig?) => AsyncIterable<T[]>

Defined in: packages/fireflow-types/src/execution/services/dbos-types.ts:298

Subscribe to a stream and return an async iterable of batched values.

Type Parameters

T

T

Parameters

workflowId

string

streamKey

string

fromOffset?

number

batchConfig?

IStreamBatchConfig

Returns

AsyncIterable<T[]>