Function: startInboundBridge()

startInboundBridge<T>(dbos, sourceWorkflowId, edgeId): object

Start an inbound stream bridge. Creates a local MultiChannel and begins pumping data from a remote DBOS stream into it.

The returned channel is immediately usable by consumers — they will receive data in real-time as it arrives from the DBOS stream.

Runs at WORKFLOW level. The pump runs concurrently (fire-and-forget) and the channel will be closed when the remote stream closes.

Type Parameters

T

DBOS context service (for readStream)

string

The workflow that writes to the stream

string

The edge ID (used to derive stream key)

object

The local MultiChannel that consumers can iterate

channel: MultiChannel<T>

done: Promise<void>