diff --git a/types/async/index.d.ts b/types/async/index.d.ts index 33bb1a6c0e..9b19f47249 100644 --- a/types/async/index.d.ts +++ b/types/async/index.d.ts @@ -28,7 +28,7 @@ interface AsyncQueue { idle(): boolean; concurrency: number; push(task: T, callback?: ErrorCallback): void; - push(task: T, callback?: AsyncResultCallback): void; + push(task: T, callback?: AsyncResultCallback): void; push(task: T[], callback?: ErrorCallback): void; unshift(task: T, callback?: ErrorCallback): void; unshift(task: T[], callback?: ErrorCallback): void; @@ -53,8 +53,8 @@ interface AsyncPriorityQueue { concurrency: number; started: boolean; paused: boolean; - push(task: T, priority: number, callback?: AsyncResultArrayCallback): void; - push(task: T[], priority: number, callback?: AsyncResultArrayCallback): void; + push(task: T, priority: number, callback?: AsyncResultArrayCallback): void; + push(task: T[], priority: number, callback?: AsyncResultArrayCallback): void; saturated: () => any; empty: () => any; drain: () => any; diff --git a/types/async/test/index.ts b/types/async/test/index.ts index b30ca4c7ba..60234a0ca4 100644 --- a/types/async/test/index.ts +++ b/types/async/test/index.ts @@ -271,9 +271,9 @@ async.waterfall([ ], function (err, result) { }); -var q = async.queue(function (task: any, callback: () => void) { +var q = async.queue(function (task: any, callback: (err?:Error,msg?:string) => void) { console.log('hello ' + task.name); - callback(); + callback(undefined,'a message.'); }, 2); @@ -291,6 +291,10 @@ q.push([{ name: 'baz' }, { name: 'bay' }, { name: 'bax' }], function (err) { console.log('finished processing bar'); }); +q.push({name: 'foo'}, function (err,msg) { + console.log('foo finished with a message "'+ msg! + '"'); +}); + q.unshift({ name: 'foo' }); q.unshift({ name: 'bar' }, function (err) {