/**
 * Runs a mapping function over an asynchronous iterable
 */
export declare function concurrentMap<TFrom, TTo>(mapper: (t: TFrom) => Promise<TTo>, concurrency: number): (source: AsyncIterable<TFrom>) => AsyncIterableIterator<TTo>;