concurrent-queue - npm Package Compare versions

Comparing version 5.0.1 to 6.0.0

index.js

@@ -44,23 +44,2 @@ var assert       = require('assert'),
     }
-    cq.limit = function (limits) {
-        limits = assign({ concurrency: Infinity, maxSize: Infinity }, limits)
-        assert(typeof limits.maxSize === 'number', 'maxSize must be a number')
-        assert(typeof limits.concurrency === 'number', 'concurrency must be a number')
-        maxSize = limits.maxSize
-        concurrency = limits.concurrency
-        return cq
-    }
-    cq.process = function (func) {
-        assert(typeof func === 'function', 'process requires a processor function')
-        assert(!processor, 'queue processor already defined')
-        processor = func
-        setImmediate(drain)
-        return cq
-    }
-    cq.enqueued = eventuate()
-    cq.rejected = eventuate()
-    cq.processingStarted = eventuate()
-    cq.processingEnded = eventuate()
-    cq.drained = eventuate()
-
     Object.defineProperties(cq, {
@@ -97,3 +76,23 @@ size: { enumerable: true, get: function () {
             return processor
-        }}
+        }},
+        limit: { value: function (limits) {
+            limits = assign({ concurrency: Infinity, maxSize: Infinity }, limits)
+            assert(typeof limits.maxSize === 'number', 'maxSize must be a number')
+            assert(typeof limits.concurrency === 'number', 'concurrency must be a number')
+            maxSize = limits.maxSize
+            concurrency = limits.concurrency
+            return cq
+        }},
+        process: { value: function (func) {
+            assert(typeof func === 'function', 'process requires a processor function')
+            assert(!processor, 'queue processor already defined')
+            processor = func
+            setImmediate(drain)
+            return cq
+        }},
+        enqueued: { value: eventuate() },
+        rejected: { value: eventuate() },
+        processingStarted: { value: eventuate() },
+        processingEnded: { value: eventuate() },
+        drained: { value: eventuate() }
     })
@@ -100,0 +99,0 @@

package.json

 {
   "name": "concurrent-queue",
-  "version": "5.0.1",
+  "version": "6.0.0",
   "description": "Fifo queue with concurrency control",
@@ -5,0 +5,0 @@ "main": "index.js",

test/events.js

@@ -67,6 +67,4 @@ var test         = require('tape'),
         var numbers = [1, 9, 3, 0, 8, 4, 7, 2, 5, 6]
-        numbers.forEach(function (num) {
-            q(num)
-        })
+        numbers.forEach(q)
     }
 })

No alert changes

Worsened metrics

Total package byte prevSize

26095

decreased by-20.01%

Number of package files

19

decreased by-9.52%

Lines of code

458

decreased by-28.77%

No dependency changes