Interface: StreamSource<TEvent>
Defined in: ports/stream-source.ts:10
Runtime port for asynchronous event stream sources (@paraharness/github).
Resolved from StreamSourceASTNode via RuntimeExecutorRegistry.streamSources[node.type].
Type Parameters
| Type Parameter | Default type | Description |
|---|---|---|
TEvent | unknown | Raw event payload type emitted by the stream. |
Methods
subscribe()
ts
subscribe(onEvent): Promise<StreamSubscriptionHandle>;Defined in: ports/stream-source.ts:20
Subscribes onEvent to incoming events from the external stream source.
Forwards each incoming event to onEvent for stream filter evaluation and signal correlation.
Parameters
| Parameter | Type | Description |
|---|---|---|
onEvent | (event) => Promise<void> | Async handler invoked for each incoming event. |
Returns
Promise<StreamSubscriptionHandle>
Subscription handle with .close().