@supercharge/promise-pool
Advanced tools
Comparing version 1.6.0 to 1.6.1
# Changelog | ||
## [1.6.0](https://github.com/supercharge/streams/compare/v1.5.0...v1.6.0) - 2020-11-03 | ||
## [1.6.1](https://github.com/supercharge/promise-pool/compare/v1.6.0...v1.6.1) - 2021-03-28 | ||
### Fixed | ||
- typing error when processing a promise pool that was created from non-static methods | ||
## [1.6.0](https://github.com/supercharge/promise-pool/compare/v1.5.0...v1.6.0) - 2020-11-03 | ||
### Added | ||
@@ -16,3 +22,3 @@ - `.handleError(handler)` method: aka “bring your own error handling”. This allows you to take over error handling from the pool. If you impelement the `.handleError` method, the pool won’t collect errors anymore. It puts error handling in your hands. | ||
## [1.5.0](https://github.com/supercharge/streams/compare/v1.4.0...v1.5.0) - 2020-09-20 | ||
## [1.5.0](https://github.com/supercharge/promise-pool/compare/v1.4.0...v1.5.0) - 2020-09-20 | ||
@@ -24,3 +30,3 @@ ### Updated | ||
## [1.4.0](https://github.com/supercharge/streams/compare/v1.3.0...v1.4.0) - 2020-09-17 | ||
## [1.4.0](https://github.com/supercharge/promise-pool/compare/v1.3.0...v1.4.0) - 2020-09-17 | ||
@@ -27,0 +33,0 @@ ### Added |
@@ -6,3 +6,3 @@ import { ReturnValue } from './return-value'; | ||
*/ | ||
private items; | ||
private readonly items; | ||
/** | ||
@@ -22,3 +22,3 @@ * The number of promises running concurrently. | ||
*/ | ||
constructor(); | ||
constructor(items?: T[]); | ||
/** | ||
@@ -47,3 +47,3 @@ * Set the number of tasks to process concurrently in the promise pool. | ||
*/ | ||
for(items: T[]): PromisePool<T>; | ||
for<T>(items: T[]): PromisePool<T>; | ||
/** | ||
@@ -50,0 +50,0 @@ * Set the items to be processed in the promise pool. |
@@ -12,5 +12,5 @@ 'use strict'; | ||
*/ | ||
constructor() { | ||
this.items = []; | ||
constructor(items) { | ||
this.concurrency = 10; | ||
this.items = items !== null && items !== void 0 ? items : []; | ||
this.errorHandler = undefined; | ||
@@ -50,5 +50,3 @@ } | ||
for(items) { | ||
return goodies_1.tap(this, () => { | ||
this.items = items; | ||
}); | ||
return new PromisePool(items).withConcurrency(this.concurrency); | ||
} | ||
@@ -55,0 +53,0 @@ /** |
{ | ||
"name": "@supercharge/promise-pool", | ||
"description": "Map-like, concurrent promise processing for Node.js", | ||
"version": "1.6.0", | ||
"author": "Marcus Pöhls <marcus@futurestud.io>", | ||
"version": "1.6.1", | ||
"author": "Marcus Pöhls <marcus@superchargejs.com>", | ||
"bugs": { | ||
@@ -10,18 +10,17 @@ "url": "https://github.com/superchargejs/promise-pool/issues" | ||
"dependencies": { | ||
"@supercharge/goodies": "~1.5.1" | ||
"@supercharge/goodies": "~1.8.0" | ||
}, | ||
"devDependencies": { | ||
"@supercharge/tsconfig": "~1.0.0", | ||
"@types/jest": "~26.0.15", | ||
"@typescript-eslint/eslint-plugin": "~4.6.1", | ||
"eslint": "~7.12.1", | ||
"eslint-config-standard": "~16.0.1", | ||
"eslint-config-standard-with-typescript": "~19.0.1", | ||
"@types/jest": "~26.0.22", | ||
"@typescript-eslint/eslint-plugin": "~4.19.0", | ||
"eslint": "~7.23.0", | ||
"eslint-config-standard": "~16.0.2", | ||
"eslint-config-standard-with-typescript": "~20.0.0", | ||
"eslint-plugin-import": "~2.22.1", | ||
"eslint-plugin-node": "~11.1.0", | ||
"eslint-plugin-promise": "~4.2.1", | ||
"eslint-plugin-standard": "~4.0.2", | ||
"jest": "~26.6.2", | ||
"eslint-plugin-promise": "~4.3.1", | ||
"jest": "~26.6.3", | ||
"jest-extended": "~0.11.5", | ||
"typescript": "~4.0.5" | ||
"typescript": "~4.2.3" | ||
}, | ||
@@ -28,0 +27,0 @@ "engines": { |
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
27088
12
20
635
+ Added@supercharge/goodies@1.8.0(transitive)
- Removed@supercharge/goodies@1.5.1(transitive)
Updated@supercharge/goodies@~1.8.0