Function pipe

packages/db-ivm/src/operators/pipe.ts:51–55

(...operators: Array<PipedOperator<any, any>>)

 * Creates a new stream by piping the input stream through a series of operators
 */
export function pipe<T>(...operators: Array<PipedOperator<any, any>>) {
  return (stream: IStreamBuilder<T>): IStreamBuilder<T> => {
    return stream.pipe(...operators)
  }
}