Skip to content

@epikodelabs/streamix


@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()?

optional onCreateStream: (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()?

optional onPipeStream: (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

PipeStreamHookContext

Returns

PipeStreamHookResult | void

Released under the MIT License.