fix: don't completely flatten arrays pushed to queue/cargo. Fixes #1645

1 files changed, 16 insertions, 6 deletions

diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index 0db96a8..01567aa 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -50,14 +50,10 @@ export default function queue(worker, concurrency, payload) {
             throw new Error('task callback must be a function');
         }
         q.started = true;
-        if (Array.isArray(data)) {
-            if (data.length === 0 && q.idle()) {
-                // call drain immediately if there are no tasks
-                return setImmediate(() => trigger('drain'));
-            }
+        /*if (Array.isArray(data)) {
 
             return data.map(datum => _insert(datum, insertAtFront, callback));
-        }
+        }*/
 
         var res;
 
@@ -151,6 +147,13 @@ export default function queue(worker, concurrency, payload) {
         started: false,
         paused: false,
         push (data, callback) {
+            if (Array.isArray(data)) {
+                if (data.length === 0 && q.idle()) {
+                    // call drain immediately if there are no tasks
+                    return setImmediate(() => trigger('drain'));
+                }
+                return data.map(datum => _insert(datum, false, callback))
+            }
             return _insert(data, false, callback);
         },
         kill () {
@@ -158,6 +161,13 @@ export default function queue(worker, concurrency, payload) {
             q._tasks.empty();
         },
         unshift (data, callback) {
+            if (Array.isArray(data)) {
+                if (data.length === 0 && q.idle()) {
+                    // call drain immediately if there are no tasks
+                    return setImmediate(() => trigger('drain'));
+                }
+                return data.map(datum => _insert(datum, true, callback))
+            }
             return _insert(data, true, callback);
         },
         remove (testFn) {