Creates a StreamTransformer that groups messages channel events into
per-message ChatModelStream instances.
A new ChatModelStream is created on message-start and closed on
message-finish. Content-block events in between are forwarded to the
active stream. Only events whose namespace exactly matches path
are processed; child namespaces are ignored.
createMessagesTransformer(
path: Namespace,
nodeFilter: string
): StreamTransformer<MessagesTransformerProjection>| Name | Type | Description |
|---|---|---|
path* | Namespace | Namespace prefix to match against incoming events. |
nodeFilter | string | If provided, only events emitted by this graph node are processed; all others are skipped. |