@epikodelabs/streamix / src/public-api / pipeSourceThrough
Function: pipeSourceThrough()
pipeSourceThrough<
TIn,TOut,Ops>(source,operators):Stream<TOut>
Defined in: projects/libraries/streamix/src/lib/abstractions/stream.ts:327
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>
Source stream.
operators
[...Ops[]]
Operators to apply, in order.
Returns
Stream<TOut>
A new Stream that emits the transformed values.