diff options
Diffstat (limited to 'lib/async.js')
| -rw-r--r-- | lib/async.js | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/async.js b/lib/async.js index ba90413..fd7a953 100644 --- a/lib/async.js +++ b/lib/async.js @@ -807,6 +807,9 @@ throw new Error('Concurrency must not be zero'); } function _insert(q, data, pos, callback) { + if (callback != null && typeof callback !== "function") { + throw new Error("task callback must be a function"); + } q.started = true; if (!_isArray(data)) { data = [data]; @@ -940,9 +943,10 @@ } function _insert(q, data, priority, callback) { - if (!q.started){ - q.started = true; + if (callback != null && typeof callback !== "function") { + throw new Error("task callback must be a function"); } + q.started = true; if (!_isArray(data)) { data = [data]; } |