@epikodelabs/streamix / StreamRuntimeHooks
Type Alias: StreamRuntimeHooks
StreamRuntimeHooks =
object
Defined in: projects/libraries/streamix/src/lib/abstractions/hooks.ts:36
Hooks that can be registered to observe or modify runtime stream behavior.
Properties
onCreateStream()?
optionalonCreateStream: (info) =>void
Defined in: projects/libraries/streamix/src/lib/abstractions/hooks.ts:38
Called when a stream is created. Useful for tracing and instrumentation.
Parameters
info
id
string
name?
string
Returns
void
onPipeStream()?
optionalonPipeStream: (ctx) =>PipeStreamHookResult|void
Defined in: projects/libraries/streamix/src/lib/abstractions/hooks.ts:44
Called when a source stream is piped through operators. Returning a PipeStreamHookResult allows modifying the source iterator, operator list or applying a final wrapper around the iterator.
Parameters
ctx
Returns
PipeStreamHookResult | void