export declare function runConcurrent<T, R>(items: T[], concurrency: number, worker: (item: T) => Promise<R>): Promise<R[]>;
export declare function runConcurrentStreaming<T, R>(items: T[], concurrency: number, worker: (item: T) => Promise<R>, onResult: (result: R, item: T) => void): Promise<void>;
//# sourceMappingURL=pool.d.ts.map