diff options
| author | Pierre Curto <pierre.curto@gmail.com> | 2012-01-30 18:04:24 +0100 |
|---|---|---|
| committer | Pierre Curto <pierre.curto@gmail.com> | 2012-01-30 18:04:24 +0100 |
| commit | 7a0eaaff4bc86a35f755fa2cfc12b08d1e278ffc (patch) | |
| tree | 3f2df3b129db52ec62f37c07a7c2f2c3557c6a9a | |
| parent | f7fec588ee9d53c22e2009a7e38e386c7d5b7ce4 (diff) | |
| download | async-7a0eaaff4bc86a35f755fa2cfc12b08d1e278ffc.tar.gz | |
#queue(): allow unspecified callbacks
| -rw-r--r-- | lib/async.js | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/async.js b/lib/async.js index c862008..286c563 100644 --- a/lib/async.js +++ b/lib/async.js @@ -594,7 +594,7 @@ empty: null, drain: null, push: function (data, callback) { - q.tasks.push({data: data, callback: callback}); + q.tasks.push({data: data, callback: typeof callback === 'function' ? callback : null}); if(q.saturated && q.tasks.length == concurrency) q.saturated(); async.nextTick(q.process); }, |