diff --git a/async/async.d.ts b/async/async.d.ts index 994ed17999..1efa5046bb 100644 --- a/async/async.d.ts +++ b/async/async.d.ts @@ -31,6 +31,23 @@ interface AsyncQueue { kill(): void; } +interface AsyncPriorityQueue { + length(): number; + concurrency: number; + started: boolean; + paused: boolean; + push(task: T, priority: number, callback?: AsyncMultipleResultsCallback): void; + push(task: T[], priority: number, callback?: AsyncMultipleResultsCallback): void; + saturated: () => any; + empty: () => any; + drain: () => any; + running(): number; + idle(): boolean; + pause(): void; + resume(): void; + kill(): void; +} + interface Async { // Collections @@ -56,7 +73,7 @@ interface Async { some(arr: T[], iterator: AsyncIterator, callback: AsyncMultipleResultsCallback): any; any(arr: T[], iterator: AsyncIterator, callback: AsyncMultipleResultsCallback): any; every(arr: T[], iterator: AsyncIterator, callback: (result: boolean) => any): any; - all(arr: T[], iterator: AsyncIterator, callback: (result: boolean) => any): any; + all(arr: T[], iterator: AsyncIterator, callback: (result: boolean) => any): any; concat(arr: T[], iterator: AsyncIterator, callback: AsyncMultipleResultsCallback): any; concatSeries(arr: T[], iterator: AsyncIterator, callback: AsyncMultipleResultsCallback): any; @@ -72,6 +89,7 @@ interface Async { waterfall(tasks: T[], callback?: AsyncMultipleResultsCallback): void; waterfall(tasks: T, callback?: AsyncMultipleResultsCallback): void; queue(worker: AsyncWorker, concurrency: number): AsyncQueue; + priorityQueue(worker: AsyncWorker, concurrency: number): AsyncPriorityQueue; // auto(tasks: any[], callback?: AsyncMultipleResultsCallback): void; auto(tasks: any, callback?: AsyncMultipleResultsCallback): void; iterator(tasks: Function[]): Function;