New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
async-promise-pool
Advanced tools
async-promise-pool - npm Package Compare versions
Comparing version 1.0.1-0 to 1.0.1-1
| "use strict"; | ||
| 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 _regenerator = require("babel-runtime/regenerator"); | ||
| function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; } | ||
| var _regenerator2 = _interopRequireDefault(_regenerator); | ||
| function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } | ||
| var _asyncToGenerator2 = require("babel-runtime/helpers/asyncToGenerator"); | ||
| var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2); | ||
| var _classCallCheck2 = require("babel-runtime/helpers/classCallCheck"); | ||
| var _classCallCheck3 = _interopRequireDefault(_classCallCheck2); | ||
| var _createClass2 = require("babel-runtime/helpers/createClass"); | ||
| var _createClass3 = _interopRequireDefault(_createClass2); | ||
| var _promise = require("babel-runtime/core-js/promise"); | ||
| var _promise2 = _interopRequireDefault(_promise); | ||
| function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
| // see: http://bluebirdjs.com/docs/api/deferred-migration.html | ||
@@ -13,3 +29,3 @@ function defer() { | ||
| var reject = function reject() {}; | ||
| var promise = new Promise(function (res, rej) { | ||
| var promise = new _promise2.default(function (res, rej) { | ||
| resolve = res; | ||
@@ -30,5 +46,3 @@ reject = rej; | ||
| var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {}; | ||
| _classCallCheck(this, PromisePool); | ||
| (0, _classCallCheck3.default)(this, PromisePool); | ||
| this.queue = []; | ||
@@ -38,5 +52,5 @@ this.pool = []; | ||
| this.concurrency = Number.MAX_VALUE; | ||
| this.next = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee() { | ||
| this.next = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee() { | ||
| var promiseProducer, result, promise; | ||
| return regeneratorRuntime.wrap(function _callee$(_context) { | ||
| return _regenerator2.default.wrap(function _callee$(_context) { | ||
| while (1) { | ||
@@ -115,3 +129,3 @@ switch (_context.prev = _context.next) { | ||
| _createClass(PromisePool, [{ | ||
| (0, _createClass3.default)(PromisePool, [{ | ||
| key: "add", | ||
@@ -128,3 +142,2 @@ value: function add(promiseProducer) { | ||
| }]); | ||
| return PromisePool; | ||
@@ -131,0 +144,0 @@ }(); |
| "use strict"; | ||
| function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; } | ||
| var _regenerator = require("babel-runtime/regenerator"); | ||
| var _regenerator2 = _interopRequireDefault(_regenerator); | ||
| var _asyncToGenerator2 = require("babel-runtime/helpers/asyncToGenerator"); | ||
| var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2); | ||
| var _promise = require("babel-runtime/core-js/promise"); | ||
| var _promise2 = _interopRequireDefault(_promise); | ||
| function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
| var PromisePool = require("."); | ||
@@ -14,3 +26,3 @@ | ||
| promiseProducer = function promiseProducer() { | ||
| return new Promise(function (resolve, reject) { | ||
| return new _promise2.default(function (resolve, reject) { | ||
| promiseSpy(); | ||
@@ -22,5 +34,5 @@ resolve("success"); | ||
| it("should await all promises", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee() { | ||
| it("should await all promises", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee() { | ||
| var pool, results; | ||
| return regeneratorRuntime.wrap(function _callee$(_context) { | ||
| return _regenerator2.default.wrap(function _callee$(_context) { | ||
| while (1) { | ||
@@ -50,5 +62,5 @@ switch (_context.prev = _context.next) { | ||
| it("should await all promises with no concurrency", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee2() { | ||
| it("should await all promises with no concurrency", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2() { | ||
| var pool, results; | ||
| return regeneratorRuntime.wrap(function _callee2$(_context2) { | ||
| return _regenerator2.default.wrap(function _callee2$(_context2) { | ||
| while (1) { | ||
@@ -79,5 +91,5 @@ switch (_context2.prev = _context2.next) { | ||
| it("should allow multiple concurrency", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee3() { | ||
| it("should allow multiple concurrency", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee3() { | ||
| var delayedPromiseSpy, delayedPromiseProducer, pool, results; | ||
| return regeneratorRuntime.wrap(function _callee3$(_context3) { | ||
| return _regenerator2.default.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
@@ -89,3 +101,3 @@ switch (_context3.prev = _context3.next) { | ||
| delayedPromiseProducer = function delayedPromiseProducer() { | ||
| return new Promise(function (resolve, reject) { | ||
| return new _promise2.default(function (resolve, reject) { | ||
| setTimeout(function () { | ||
@@ -121,5 +133,5 @@ delayedPromiseSpy(); | ||
| it("can be called multiple times", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee4() { | ||
| it("can be called multiple times", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee4() { | ||
| var pool, results; | ||
| return regeneratorRuntime.wrap(function _callee4$(_context4) { | ||
| return _regenerator2.default.wrap(function _callee4$(_context4) { | ||
| while (1) { | ||
@@ -154,5 +166,5 @@ switch (_context4.prev = _context4.next) { | ||
| it("should throw if .all fails", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee5() { | ||
| it("should throw if .all fails", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee5() { | ||
| var pool, error, errorProducer; | ||
| return regeneratorRuntime.wrap(function _callee5$(_context5) { | ||
| return _regenerator2.default.wrap(function _callee5$(_context5) { | ||
| while (1) { | ||
@@ -165,3 +177,3 @@ switch (_context5.prev = _context5.next) { | ||
| errorProducer = function errorProducer() { | ||
| return new Promise(function (resolve, reject) { | ||
| return new _promise2.default(function (resolve, reject) { | ||
| reject(new Error("Test")); | ||
@@ -200,5 +212,5 @@ }); | ||
| it("should throw if any promise fails outside of .all", _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee6() { | ||
| it("should throw if any promise fails outside of .all", (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee6() { | ||
| var pool, error, errorProducer; | ||
| return regeneratorRuntime.wrap(function _callee6$(_context6) { | ||
| return _regenerator2.default.wrap(function _callee6$(_context6) { | ||
| while (1) { | ||
@@ -211,3 +223,3 @@ switch (_context6.prev = _context6.next) { | ||
| errorProducer = function errorProducer() { | ||
| return new Promise(function (resolve, reject) { | ||
| return new _promise2.default(function (resolve, reject) { | ||
| reject(new Error("Test")); | ||
@@ -214,0 +226,0 @@ }); |
| { | ||
| "name": "async-promise-pool", | ||
| "version": "1.0.1-0", | ||
| "version": "1.0.1-1", | ||
| "description": "A flexible pool of promises that can be awaited and executed at a chosen level of concurrency", | ||
| "main": "index.js", | ||
| "main": "lib/index.js", | ||
| "scripts": { | ||
@@ -16,2 +16,3 @@ "build": "babel src -d lib", | ||
| "babel-plugin-transform-class-properties": "^6.24.1", | ||
| "babel-plugin-transform-runtime": "^6.23.0", | ||
| "babel-preset-env": "^1.6.1", | ||
@@ -18,0 +19,0 @@ "babel-preset-flow": "^6.23.0", |
Sorry, the diff of this file is not supported yet
No alert changes
Improved metrics
- Lines of code
- increased by3.77%
303
Worsened metrics
- Total package byte prevSize
- decreased by-1.03%
13978
- Dev dependency count
- increased by11.11%
10
No dependency changes