Packages › trotsky › StepBuilderStream › apply
StepBuilderStream.apply() method
Applies the stream logic by listening to events from the event emitter and processing them sequentially. Messages are handled using a queue to ensure sequential execution.
Signature:
typescript
/** @override */
apply(): Promise<void>;Returns:
Promise<void>
A promise that resolves when the stream processing is complete or rejects on error.