Function pipe

Pipe a stream (or anything else) through a series of single-argument functions/operators

e.g. the following creates a stream that outputs 4 and then 6:

pipe(fromIterable([1,2,3,4]), skip(1), take(2), map(x => x*2))
Copy

The first argument to pipe() can be any value, but all other arguments must be functions. The value is passed to the first function, and then the result is passed to the next function in turn, until all provided functions have been called with the result of the previous function. The return value is the last result, or the original value if no functions were given.

The underlying implementation of pipe() works with any number of arguments, but due to TypeScript limitations we only have typing defined for a max of 9 functions (10 arguments total). If you need more than 9 functions, you can stack some of them with compose(), e.g.:

pipe(
    aStream,
    compose(op1, op2, ...),
    compose(op10, op11, ...),
    compose(op19, ...),
    ...
)
Copy