redis-semaphore
Advanced tools
Comparing version
@@ -1,2 +0,2 @@ | ||
exports.mutex = require('./lib/mutex') | ||
exports.semaphore = require('./lib/semaphore') | ||
exports.Mutex = require('./lib/Mutex') | ||
exports.Semaphore = require('./lib/Semaphore') |
@@ -1,2 +0,2 @@ | ||
module.exports = function RedisSemaphoreTimeoutError(message) { | ||
module.exports = function TimeoutError(message) { | ||
this.name = this.constructor.name | ||
@@ -3,0 +3,0 @@ this.message = message |
{ | ||
"name": "redis-semaphore", | ||
"version": "0.1.0", | ||
"version": "0.2.0", | ||
"description": "Distributed mutex and semaphore based on Redis", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -42,3 +42,3 @@ /* global expect client */ | ||
const id2 = await acquire(client, 'key', 2, 50, 50, 10) | ||
expect(await client.zrangeAsync('semaphore:key', 0, -1)).to.be.eql([ | ||
expect(await client.zrangeAsync('semaphore:key', 0, -1)).to.have.members([ | ||
id1, | ||
@@ -48,3 +48,3 @@ id2 | ||
await refresh(client, 'key', id1) | ||
expect(await client.zrangeAsync('semaphore:key', 0, -1)).to.be.eql([ | ||
expect(await client.zrangeAsync('semaphore:key', 0, -1)).to.have.members([ | ||
id2, | ||
@@ -51,0 +51,0 @@ id1 |
110250
9.59%37
15.63%812
58.9%