@epikodelabs/streamix

---

@epikodelabs/streamix / PipeResult

Type Alias: PipeResult<T, Ops>

PipeResult<T, Ops> = Ops extends [] ? Stream<T> : Ops extends [Operator<T, infer A>, ...(infer Rest)] ? Rest extends Operator<any, any>[] ? PipeResult<A, Rest> : Stream<any> : Stream<any>

Defined in: projects/libraries/streamix/src/lib/abstractions/operator.ts:257

Recursive conditional type that computes the output type of a chain of operators.

Walks the operator array left-to-right, threading each operator's output type into the next operator's input type. Returns Stream<T> for an empty chain, and falls back to Stream<any> if type inference is exhausted.

Type Parameters

T

T

The initial stream value type.

Ops

Ops extends readonly Operator<any, any>[]

The tuple of operators to apply.