export interface ConcurrentMapOptions {
    concurrency?: number;
    signal?: AbortSignal;
    stopOnError?: boolean;
}
export interface ConcurrentQueue {
    run<Type>(task: () => Promise<Type>, options?: {
        signal?: AbortSignal;
    }): Promise<Type>;
    getQueueLength(): number;
    getRunningCount(): number;
}
export declare function raceAbort<Type>(promise: Promise<Type>, signal?: AbortSignal): Promise<Type>;
export declare function mapConcurrent<Type, Result>(items: readonly Type[], options: ConcurrentMapOptions, fn: (item: Type, index: number) => Promise<Result> | Result): Promise<Result[]>;
export declare function forEachConcurrent<Type>(items: readonly Type[], options: ConcurrentMapOptions, fn: (item: Type, index: number) => Promise<void> | void): Promise<void>;
export declare function createConcurrentQueue(concurrency: number): ConcurrentQueue;