import { OperatorAsyncFunction } from '../interfaces'; import { Observable } from '../observer'; /** * This clas serves as the base for all operations which support [Symbol.asyncIterator]. */ export declare abstract class AsyncIterableX implements AsyncIterable { abstract [Symbol.asyncIterator](): AsyncIterator; forEach(projection: (value: T, index: number) => void | Promise, thisArg?: any): Promise; static as(source: string): AsyncIterableX; static as(source: AsyncIterableInput): AsyncIterableX; static as(source: T): AsyncIterableX; static from(source: AsyncIterableInput, selector?: (value: TSource, index: number) => TResult | Promise, thisArg?: any): AsyncIterableX; static of(...args: TSource[]): AsyncIterableX; } export declare type AsyncIterableInput = AsyncIterable | Iterable> | ArrayLike | PromiseLike | Observable; declare module '../asynciterable/asynciterablex' { interface AsyncIterableX { pipe(): AsyncIterableX; 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: OperatorAsyncFunction[]): AsyncIterableX; } }