@saulx/utils
Advanced tools
Comparing version 4.0.0 to 4.0.1
@@ -17,4 +17,2 @@ import deepCopy from './deepCopy.js'; | ||
export * from './query.js'; | ||
export * from './base64.js'; | ||
export * from './utf8.js'; | ||
export * from './path.js'; |
@@ -17,5 +17,3 @@ import deepCopy from './deepCopy.js'; | ||
export * from './query.js'; | ||
export * from './base64.js'; | ||
export * from './utf8.js'; | ||
export * from './path.js'; | ||
//# sourceMappingURL=index.js.map |
@@ -63,3 +63,2 @@ import { hash, hashObjectIgnoreKeyOrder } from '@saulx/hash'; | ||
keysInProgress.add(key); | ||
// @ts-ignore | ||
promiseFn(...l.args) | ||
@@ -90,12 +89,12 @@ .then((v) => { | ||
return new Promise((resolve, reject) => { | ||
// @ts-ignore | ||
const id = opts.dedup(...args); | ||
if (!listeners[id]) { | ||
listeners[id] = { args, listeners: [[resolve, reject]] }; | ||
if ('dedup' in opts) { | ||
const id = opts.dedup(...args); | ||
if (!listeners[id]) { | ||
listeners[id] = { args, listeners: [[resolve, reject]] }; | ||
} | ||
else { | ||
listeners[id].listeners.push([resolve, reject]); | ||
} | ||
} | ||
else { | ||
listeners[id].listeners.push([resolve, reject]); | ||
} | ||
// @ts-ignore | ||
if (keysInProgress.size < opts.concurrency) { | ||
if (keysInProgress.size < (opts.concurrency ?? 1)) { | ||
drain(); | ||
@@ -102,0 +101,0 @@ } |
@@ -0,3 +1,4 @@ | ||
/// <reference types="node" resolution-mode="require"/> | ||
import { Stream } from 'stream'; | ||
declare const _default: (stream: Stream) => Promise<Buffer>; | ||
export default _default; |
{ | ||
"name": "@saulx/utils", | ||
"version": "4.0.0", | ||
"version": "4.0.1", | ||
"repository": "https://github.com/atelier-saulx/utils", | ||
@@ -5,0 +5,0 @@ "files": [ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
0
77131
60
1139