diff options
Diffstat (limited to 'lib/queue.js')
-rw-r--r-- | lib/queue.js | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/lib/queue.js b/lib/queue.js new file mode 100644 index 0000000..de2ac93 --- /dev/null +++ b/lib/queue.js @@ -0,0 +1,9 @@ +'use strict'; + +import queue from './internal/queue'; + +export default function (worker, concurrency) { + return queue(function (items, cb) { + worker(items[0], cb); + }, concurrency, 1); +} |