@epikodelabs/streamix / pipeSourceThrough
Function: pipeSourceThrough()
pipeSourceThrough<
TIn,Ops>(source,operators):Stream<any>
Defined in: projects/libraries/streamix/src/lib/abstractions/stream.ts:372
Applies a list of operators to a source stream and returns the resulting stream.
This is the implementation behind stream.pipe(...). It creates a new stream identity (stream id) for the piped stream and ensures runtime hooks are invoked consistently for both subscribe() and direct async iteration.
Type Parameters
TIn
TIn
Source value type.
Ops
Ops extends Operator<any, any>[]
Parameters
source
Stream<TIn>
Source stream.
operators
[...Ops[]]
Operators to apply, in order.
Returns
Stream<any>
A new Stream that emits the transformed values.