bottleneckp
Advanced tools
Comparing version 1.0.2 to 1.0.3
@@ -94,3 +94,3 @@ var PriorityQueue = function(size) { | ||
} | ||
priority = priority && + priority | 0 || self._defaultPriority; | ||
priority = Number.isInteger(priority) ? priority: self._defaultPriority; | ||
priority = priority > self._priorityRange-1 ? self._priorityRange-1 : priority; | ||
@@ -97,0 +97,0 @@ this._waitingClients.enqueue(clientCallback, priority); |
{ | ||
"name": "bottleneckp", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "asynchronous rate limiter with priority", | ||
@@ -5,0 +5,0 @@ "main": "./lib/Bottleneck.js", |
@@ -75,3 +75,3 @@ describe('General', function () { | ||
console.assert(c.size() === 3) | ||
c.limiter.submit(2, c.job(5)) | ||
c.limiter.submit(0, c.job(5)) | ||
console.assert(c.size() === 4) | ||
@@ -88,3 +88,3 @@ }) | ||
console.assert(c.size() === 0) | ||
c.limiter.submit(2, c.job(4)) | ||
c.limiter.submit(0, c.job(4)) | ||
console.assert(c.size() === 0) | ||
@@ -97,3 +97,3 @@ c.limiter.submit(5, c.job(5)) | ||
console.assert(c.size() === 0) | ||
c.limiter.submit(2, c.job(8)) | ||
c.limiter.submit(0, c.job(8)) | ||
console.assert(c.size() === 0) | ||
@@ -106,3 +106,3 @@ c.limiter.submit(5, c.job(9)) | ||
console.assert(c.size() === 1) | ||
c.limiter.submit(2, c.job(12)) | ||
c.limiter.submit(0, c.job(12)) | ||
console.assert(c.size() === 2) | ||
@@ -109,0 +109,0 @@ c.limiter.submit(9, c.last(13, { |
13365