UNPKG

1.26 kBTypeScriptView Raw
1import { AsyncIterableInput, AsyncIterableX } from './asynciterablex';
2import { Observable } from '../observer';
3export declare let from: <TSource, TResult = TSource>(source: AsyncIterableInput<TSource>, selector?: (value: TSource, index: number) => TResult | Promise<TResult>, thisArg?: any) => AsyncIterableX<TResult>;
4export declare let FromArrayIterable: new <TSource, TResult = TSource>(source: ArrayLike<TSource>, selector: (value: TSource, index: number) => TResult | Promise<TResult>) => AsyncIterableX<TResult>;
5export declare let FromAsyncIterable: new <TSource, TResult = TSource>(source: Iterable<TSource | PromiseLike<TSource>> | AsyncIterable<TSource>, selector: (value: TSource, index: number) => TResult | Promise<TResult>) => AsyncIterableX<TResult>;
6export declare let FromPromiseIterable: new <TSource, TResult = TSource>(source: PromiseLike<TSource>, selector: (value: TSource, index: number) => TResult | Promise<TResult>) => AsyncIterableX<TResult>;
7export declare let FromObservableAsyncIterable: new <TSource, TResult = TSource>(observable: Observable<TSource>, selector: (value: TSource, index: number) => TResult | Promise<TResult>) => AsyncIterableX<TResult>;
8export declare function _initialize(Ctor: typeof AsyncIterableX): void;