Interface: StreamNode<TEvent, TPayload>

Defined in: ast/stream-node.ts:14

Passive AST node representing an inbound event stream (P.stream(id)).

Subscribes to a StreamSourceASTNode<TEvent>, optionally filters inbound events via filterFn, and projects matching events into a typed SignalNode<TPayload> via mapPayload.

Type Parameters

Type Parameter	Default type	Description
TEvent	unknown	Inbound raw event type emitted by source.
TPayload	unknown	Outbound signal payload type emitted into the harness.

Properties

Property	Modifier	Type	Description	Defined in
filterFn?	readonly	BivariantCallback<[event: TEvent], boolean>	Optional synchronous predicate filtering raw events before signal emission.	ast/stream-node.ts:22
id	readonly	string	Unique identifier of the stream definition.	ast/stream-node.ts:18
mapPayload	readonly	BivariantCallback<[event: TEvent], TPayload>	Synchronous mapper projecting a matched TEvent into TPayload.	ast/stream-node.ts:26
signal	readonly	SignalNode<TPayload>	Target SignalNode<TPayload> emitted when an event matches.	ast/stream-node.ts:24
source	readonly	GithubWebhookStreamNode<TEvent>	Passive stream source AST node providing inbound events.	ast/stream-node.ts:20
type	readonly	"harness:stream"	Discriminant identifying an inbound stream AST node.	ast/stream-node.ts:16