/** * Default parameters */ declare const defaultQueueParams: ConcurrentQueriesCommonParams; /** * Callback to get query */ type GetConcurrentQueryCallback = (index: number) => Promise; /** * Parameters */ interface ConcurrentQueriesCommonParams { limit?: number; retries?: number; onError?: (index: number, error: unknown, params: ConcurrentQueriesParams) => void | Promise; onSuccess?: (index: number, params: ConcurrentQueriesParams, result: T) => void; onStart?: (index: number, params: ConcurrentQueriesParams) => void; } interface ConcurrentQueriesParamsWithCount extends ConcurrentQueriesCommonParams { total: number; callback: (index: number) => Promise; } interface ConcurrentQueriesParamsWithPromises extends ConcurrentQueriesCommonParams { promises: Promise[]; } type ConcurrentQueriesParams = ConcurrentQueriesParamsWithCount | ConcurrentQueriesParamsWithPromises; /** * Runs concurrent async operations */ declare function runConcurrentQueries(params: ConcurrentQueriesParams): Promise; export { ConcurrentQueriesCommonParams, ConcurrentQueriesParams, ConcurrentQueriesParamsWithCount, ConcurrentQueriesParamsWithPromises, GetConcurrentQueryCallback, defaultQueueParams, runConcurrentQueries };