/// export * from './Ix'; import './add/asynciterable/fromnodestream'; import './add/iterable-operators/tonodestream'; import './add/asynciterable-operators/tonodestream'; export { IterableReadable } from './iterable/tonodestream'; export { AsyncIterableReadable } from './asynciterable/tonodestream'; export { fromNodeStream, ReadableStreamAsyncIterable } from './asynciterable/fromnodestream'; import { OperatorAsyncFunction } from './interfaces'; declare module './asynciterable/asynciterablex' { interface AsyncIterableX { pipe(): AsyncIterableX; pipe(op1: A): A; pipe(op1: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction, op5: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction, op5: OperatorAsyncFunction, op6: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction, op5: OperatorAsyncFunction, op6: OperatorAsyncFunction, op7: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction, op5: OperatorAsyncFunction, op6: OperatorAsyncFunction, op7: OperatorAsyncFunction, op8: OperatorAsyncFunction): AsyncIterableX; pipe(op1: OperatorAsyncFunction, op2: OperatorAsyncFunction, op3: OperatorAsyncFunction, op4: OperatorAsyncFunction, op5: OperatorAsyncFunction, op6: OperatorAsyncFunction, op7: OperatorAsyncFunction, op8: OperatorAsyncFunction, op9: OperatorAsyncFunction): AsyncIterableX; pipe(...operations: (NodeJS.WritableStream | NodeJS.ReadWriteStream | OperatorAsyncFunction)[]): AsyncIterableX; } }