Socket
Socket
Sign inDemoInstall

@supercharge/promise-pool

Package Overview
Dependencies
0
Maintainers
3
Versions
24
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 1.6.2 to 1.7.0

10

CHANGELOG.md
# Changelog
## [1.7.0](https://github.com/supercharge/promise-pool/compare/v1.6.2...v1.7.0) - 2021-04-11
### Updated
- bump dependencies
- refactored code to not use the `@supercharge/goodies` package
### Removed
- dependency to `@supercharge/goodies`
## [1.6.2](https://github.com/supercharge/promise-pool/compare/v1.6.1...v1.6.2) - 2021-04-09

@@ -5,0 +15,0 @@

26

dist/promise-pool-executor.js
'use strict';
Object.defineProperty(exports, "__esModule", { value: true });
exports.PromisePoolExecutor = void 0;
const goodies_1 = require("@supercharge/goodies");
const promise_pool_error_1 = require("./promise-pool-error");

@@ -27,5 +26,4 @@ class PromisePoolExecutor {

withConcurrency(concurrency) {
return goodies_1.tap(this, () => {
this.concurrency = concurrency;
});
this.concurrency = concurrency;
return this;
}

@@ -40,5 +38,4 @@ /**

for(items) {
return goodies_1.tap(this, () => {
this.items = items;
});
this.items = items;
return this;
}

@@ -53,5 +50,4 @@ /**

withHandler(action) {
return goodies_1.tap(this, () => {
this.handler = action;
});
this.handler = action;
return this;
}

@@ -66,5 +62,4 @@ /**

handleError(handler) {
return goodies_1.tap(this, () => {
this.errorHandler = handler;
});
this.errorHandler = handler;
return this;
}

@@ -93,5 +88,4 @@ /**

async start() {
return goodies_1.upon(this.validateInputs(), async () => {
return this.process();
});
this.validateInputs();
return await this.process();
}

@@ -98,0 +92,0 @@ /**

'use strict';
Object.defineProperty(exports, "__esModule", { value: true });
exports.PromisePool = void 0;
const goodies_1 = require("@supercharge/goodies");
const promise_pool_executor_1 = require("./promise-pool-executor");

@@ -25,5 +24,4 @@ class PromisePool {

withConcurrency(concurrency) {
return goodies_1.tap(this, () => {
this.concurrency = concurrency;
});
this.concurrency = concurrency;
return this;
}

@@ -68,5 +66,4 @@ /**

handleError(handler) {
return goodies_1.tap(this, () => {
this.errorHandler = handler;
});
this.errorHandler = handler;
return this;
}

@@ -73,0 +70,0 @@ /**

{
"name": "@supercharge/promise-pool",
"description": "Map-like, concurrent promise processing for Node.js",
"version": "1.6.2",
"version": "1.7.0",
"author": "Marcus Pöhls <marcus@superchargejs.com>",

@@ -9,5 +9,3 @@ "bugs": {

},
"dependencies": {
"@supercharge/goodies": "~1.8.0"
},
"dependencies": {},
"devDependencies": {

@@ -17,4 +15,3 @@ "@supercharge/tsconfig": "~1.0.0",

"@typescript-eslint/eslint-plugin": "~4.21.0",
"eslint": "~7.23.0",
"eslint-config-standard": "~16.0.2",
"eslint": "~7.24.0",
"eslint-config-standard-with-typescript": "~20.0.0",

@@ -21,0 +18,0 @@ "eslint-plugin-import": "~2.22.1",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc