ronomon-queue
Advanced tools
Comparing version 0.1.1 to 0.1.2
@@ -9,2 +9,5 @@ var PROCESSING = 1; | ||
var self = this; | ||
if (arguments.length > 1) { | ||
throw new Error('too many arguments'); | ||
} | ||
self.concurrency = Queue.parseConcurrency(concurrency); | ||
@@ -16,2 +19,3 @@ self.pending = 0; | ||
self.stopped = false; | ||
self.done = undefined; | ||
self._flags = 0; | ||
@@ -114,2 +118,5 @@ self._arrays = []; | ||
if (self._flags & CLOSED) return; | ||
if (self.done !== undefined) { | ||
throw new Error('deprecated use of `queue.done`'); | ||
} | ||
if (error && !(self._flags & CLOSING)) { | ||
@@ -116,0 +123,0 @@ self._flags |= CLOSING; |
{ | ||
"name": "ronomon-queue", | ||
"version": "0.1.1", | ||
"version": "0.1.2", | ||
"description": "Process thousands of asynchronous or synchronous jobs, concurrently or sequentially, safely and efficiently, without creating thousands of closures.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
22465
530