await-lock
Advanced tools
Comparing version 1.1.0 to 1.1.1
@@ -1,9 +0,17 @@ | ||
"use strict"; | ||
'use strict'; | ||
var _prototypeProperties = function (child, staticProps, instanceProps) { if (staticProps) Object.defineProperties(child, staticProps); if (instanceProps) Object.defineProperties(child.prototype, instanceProps); }; | ||
Object.defineProperty(exports, '__esModule', { | ||
value: true | ||
}); | ||
var _classCallCheck = function (instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }; | ||
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })(); | ||
var assert = require("assert"); | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; } | ||
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } } | ||
var _assert = require('assert'); | ||
var _assert2 = _interopRequireDefault(_assert); | ||
var AwaitLock = (function () { | ||
@@ -17,32 +25,28 @@ function AwaitLock() { | ||
_prototypeProperties(AwaitLock, null, { | ||
acquireAsync: { | ||
value: function acquireAsync() { | ||
var _this = this; | ||
if (!this._acquired) { | ||
this._acquired = true; | ||
return Promise.resolve(); | ||
} | ||
_createClass(AwaitLock, [{ | ||
key: 'acquireAsync', | ||
value: function acquireAsync() { | ||
var _this = this; | ||
return new Promise(function (resolve, reject) { | ||
_this._waitingResolvers.push(resolve); | ||
}); | ||
}, | ||
writable: true, | ||
configurable: true | ||
}, | ||
release: { | ||
value: function release() { | ||
assert(this._acquired, "Trying to release an unacquired lock"); | ||
if (this._waitingResolvers.length > 0) { | ||
var resolve = this._waitingResolvers.shift(); | ||
resolve(); | ||
} else { | ||
this._acquired = false; | ||
} | ||
}, | ||
writable: true, | ||
configurable: true | ||
if (!this._acquired) { | ||
this._acquired = true; | ||
return Promise.resolve(); | ||
} | ||
return new Promise(function (resolve) { | ||
_this._waitingResolvers.push(resolve); | ||
}); | ||
} | ||
}); | ||
}, { | ||
key: 'release', | ||
value: function release() { | ||
(0, _assert2['default'])(this._acquired, 'Trying to release an unacquired lock'); | ||
if (this._waitingResolvers.length > 0) { | ||
var resolve = this._waitingResolvers.shift(); | ||
resolve(); | ||
} else { | ||
this._acquired = false; | ||
} | ||
} | ||
}]); | ||
@@ -52,2 +56,3 @@ return AwaitLock; | ||
module.exports = AwaitLock; | ||
exports['default'] = AwaitLock; | ||
module.exports = exports['default']; |
{ | ||
"name": "await-lock", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Mutex locks for ES7 async functions and delegating generator functions", | ||
@@ -10,3 +10,3 @@ "main": "build/AwaitLock.js", | ||
"scripts": { | ||
"prepublish": "6to5 --out-dir build src", | ||
"prepublish": "babel --out-dir build src", | ||
"test": "echo \"Error: no test specified\" && exit 1" | ||
@@ -35,4 +35,4 @@ }, | ||
"devDependencies": { | ||
"6to5": "^3.3.12" | ||
"babel": "^5.4.7" | ||
} | ||
} |
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
4511
43