@epikodelabs/streamix / pipeSourceThrough
Function: pipeSourceThrough()
pipeSourceThrough<
TIn,TOut,Ops>(source,operators):Stream<TIn,TOut>
Defined in: projects/libraries/streamix/src/lib/abstractions/stream.ts:286
Applies a list of operators to a source stream and returns the resulting stream.
This is the implementation behind stream.pipe(...).
Type Parameters
TIn
TIn
Source value type.
TOut
TOut = TIn
Ops
Ops extends Operator<any, any>[] = Operator<any, any>[]
Parameters
source
Stream<TIn, any>
Source stream.
operators
[...Ops[]]
Operators to apply, in order.
Returns
Stream<TIn, TOut>
A new Stream that emits the transformed values.