@supercharge/promise-pool
Advanced tools
Comparing version 1.6.2 to 1.7.0
# 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 @@ |
'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", |
0
11
26958
621
- Removed@supercharge/goodies@~1.8.0
- Removed@supercharge/goodies@1.8.0(transitive)