Packages › trotsky › StepBuilderStream › onMessage
StepBuilderStream.onMessage() method
Processes a Jetstream message by executing child steps for valid commit events.
Signature:
typescript
onMessage(message: JetstreamMessage): Promise<void>;Parameters
Parameter | Type | Description |
|---|---|---|
message | JetstreamMessage | The incoming Jetstream message. |
Returns:
Promise<void>
A promise that resolves when the message has been processed.