@masx200/async-task-current-limiter - npm Package Compare versions

Comparing version 1.0.9 to 2.0.0

dist/index.d.ts

@@ -0,1 +1,2 @@
+import { EventEmitterTarget } from "@masx200/event-emitter-target";
 type 空闲状态 = "free" | "full";
@@ -15,3 +16,3 @@ declare function createlimiter(max: number): AsyncCurrentLimiter;
     };
-    target: import("@masx200/event-emitter-target").EventEmitterTarget;
+    target: EventEmitterTarget;
 }
@@ -35,7 +36,2 @@ interface statusdata {
 declare const _default: AsyncLimiterConstructor;
-export {
-    _default as default,
-    AsyncLimiterConstructor,
-    AsyncCurrentLimiter,
-    statusdata,
-};
+export { _default as default, AsyncLimiterConstructor, AsyncCurrentLimiter, statusdata };

dist/index.js

@@ -1,2 +0,2 @@
-function t(){return{}.toString.call({[Symbol.toStringTag]:"EventEmitterTarget"})}function e(t){if("string"!=typeof t&&"symbol"!=typeof t)throw new TypeError(" EVENTNAME expected: string | symbol;but invalid :"+t)}function n(t){if("function"!=typeof t)throw new TypeError(" EVENTLISTENER expected: (event?: any) => void;but invalid:"+t)}function r(){const r=new Map,o=new WeakMap;function i(t){let e=r.get(t);return e||(e=new Set,r.set(t,e)),e}function u(t){e(t),r.has(t)&&i(t).clear()}function c(t,n){e(t),r.has(t)&&i(t).forEach(t=>{Promise.resolve().then(()=>{t(n)})})}function s(t,r){e(t),n(r),i(t).add(r)}function f(t,e){i(t).delete(e)}function l(t,r){e(t),n(r),f(t,r),function(t,e){const n=i(t);let r=o.get(e);r&&n.delete(r)}(t,r)}function a(){return[...r].map(([t,e])=>[t,[...e]])[Symbol.iterator]()}return{[Symbol.toPrimitive]:t,[Symbol.toStringTag]:"EventEmitterTarget",[Symbol.iterator]:a,entries:a,listenerCount:function(t){return e(t),r.has(t)?i(t).size:0},clear:u,removeAllListeners:u,on:s,addListener:s,off:l,removeListener:l,once:function(t,r){e(t),n(r);let i=!1,u=o.get(r);if(!u){const e=n=>{f(t,e),f(t,r),i||(i=!0,r(n))};u=e,o.set(r,u)}f(t,r),s(t,u)},emit:c,dispatch:c,eventNames:function(){return[...r.keys()]},listeners:function(t){return e(t),r.has(t)?[...i(t)]:[]}}}const o=(t=>{var e=Symbol(),n=new Function("return async()=>{}")()();function o(){const t=r();return this&&this instanceof o?(Object.assign(this,t),this):Reflect.construct(o,[])}return Reflect.set(o,e,n),o})();function i(t){if(!("number"==typeof t&&t>0&&1/0>t))throw TypeError(" MAX expected: number;but invalid:"+t);const e=t,n=new Map;let r=0,i=0;const u=o(),c=[];let s=!0;function f(){const t=r;if(!s)return;if(t>=c.length)return void(s=!1);if("full"===a())return void(s=!1);!function(){if(!(i<e))throw Error();i++,h()}();const o=c[t];if(!o)throw Error();const[u,l]=o,m=Promise.resolve(Reflect.apply(u,void 0,l)),g=()=>{const e=n.get(t);if(!e)throw new Error;e.resolve(m),function(){if(i-1<0)throw Error();i--,h()}(),c[t]=void 0,n.delete(t)};m.then(g,g),r++,Promise.resolve().then(()=>{f()})}function l(t){let e=c.length;c.push(t),"free"===a()&&(s=!0,f());const r=function(){let t=t=>{},e=t=>{};return{promise:new Promise((n,r)=>{t=n,e=r}),reject:e,resolve:t}}();return n.set(e,r),Promise.resolve(r.promise)}function a(){return i<e?"free":"full"}u.on("free",()=>{s=!0,f()}),u.on("full",()=>{s=!1});const m={[Symbol.toStringTag]:"AsyncCurrentLimiter",asyncwrap:function(t){return async function(...e){return await l([t,e])}},status:a,limiter:{get max(){return e},get current(){return i}},queue:{get max(){return c.length},get current(){return r}},target:u};function h(){const{queue:t,limiter:n}=m,r={status:a(),queue:{max:t.max,current:t.current},limiter:{max:n.max,current:n.current}};i>=e?u.emit("full",r):u.emit("free",r)}return m}var u=(()=>{var t=new Function("return async()=>{}")()(),e=Symbol();function n(t){const e=i(t);return this&&this instanceof n?(Object.assign(this,e),this):Reflect.construct(n,[t])}return Reflect.set(n,e,t),n})();export default u;
+import e from"@masx200/event-emitter-target";function t(t){if(!("number"==typeof t&&t>0&&1/0>t))throw TypeError(" MAX expected: number;but invalid:"+t);const r=t,n=new Map;let o=0,u=0;const i=e(),s=[];let c=!0;function f(){const e=o;if(!c)return;if(e>=s.length)return void(c=!1);if("full"===a())return void(c=!1);!function(){if(!(u<r))throw Error();u++,h()}();const t=s[e];if(!t)throw Error();const[i,l]=t,m=Promise.resolve(Reflect.apply(i,void 0,l)),g=()=>{const t=n.get(e);if(!t)throw new Error;t.resolve(m),function(){if(u-1<0)throw Error();u--,h()}(),s[e]=void 0,n.delete(e)};m.then(g,g),o++,Promise.resolve().then((()=>{f()}))}function l(e){let t=s.length;s.push(e),"free"===a()&&(c=!0,f());const r=function(){let e=e=>{},t=e=>{};return{promise:new Promise(((r,n)=>{e=r,t=n})),reject:t,resolve:e}}();return n.set(t,r),Promise.resolve(r.promise)}function a(){return u<r?"free":"full"}i.on("free",(()=>{c=!0,f()})),i.on("full",(()=>{c=!1}));const m={[Symbol.toStringTag]:"AsyncCurrentLimiter",asyncwrap:function(e){return async function(...t){return await l([e,t])}},status:a,limiter:{get max(){return r},get current(){return u}},queue:{get max(){return s.length},get current(){return o}},target:i};function h(){const{queue:e,limiter:t}=m,n={status:a(),queue:{max:e.max,current:e.current},limiter:{max:t.max,current:t.current}};u>=r?i.emit("full",n):i.emit("free",n)}return m}var r=(()=>{var e=new Function("return async()=>{}")()(),r=Symbol();function n(e){const r=t(e);return this&&this instanceof n?(Object.assign(this,r),this):Reflect.construct(n,[e])}return Reflect.set(n,r,e),n})();export{r as default};
 //# sourceMappingURL=index.js.map

dist/index.min.js

@@ -1,2 +0,2 @@
-function t(){return{}.toString.call({[Symbol.toStringTag]:"EventEmitterTarget"})}function e(t){if("string"!=typeof t&&"symbol"!=typeof t)throw new TypeError(" EVENTNAME expected: string | symbol;but invalid :"+t)}function n(t){if("function"!=typeof t)throw new TypeError(" EVENTLISTENER expected: (event?: any) => void;but invalid:"+t)}function r(){const r=new Map,o=new WeakMap;function i(t){let e=r.get(t);return e||(e=new Set,r.set(t,e)),e}function u(t){e(t),r.has(t)&&i(t).clear()}function c(t,n){e(t),r.has(t)&&i(t).forEach(t=>{Promise.resolve().then(()=>{t(n)})})}function s(t,r){e(t),n(r),i(t).add(r)}function f(t,e){i(t).delete(e)}function l(t,r){e(t),n(r),f(t,r),function(t,e){const n=i(t);let r=o.get(e);r&&n.delete(r)}(t,r)}function a(){return[...r].map(([t,e])=>[t,[...e]])[Symbol.iterator]()}return{[Symbol.toPrimitive]:t,[Symbol.toStringTag]:"EventEmitterTarget",[Symbol.iterator]:a,entries:a,listenerCount:function(t){return e(t),r.has(t)?i(t).size:0},clear:u,removeAllListeners:u,on:s,addListener:s,off:l,removeListener:l,once:function(t,r){e(t),n(r);let i=!1,u=o.get(r);if(!u){const e=n=>{f(t,e),f(t,r),i||(i=!0,r(n))};u=e,o.set(r,u)}f(t,r),s(t,u)},emit:c,dispatch:c,eventNames:function(){return[...r.keys()]},listeners:function(t){return e(t),r.has(t)?[...i(t)]:[]}}}const o=(t=>{var e=Symbol(),n=new Function("return async()=>{}")()();function o(){const t=r();return this&&this instanceof o?(Object.assign(this,t),this):Reflect.construct(o,[])}return Reflect.set(o,e,n),o})();function i(t){if(!("number"==typeof t&&t>0&&1/0>t))throw TypeError(" MAX expected: number;but invalid:"+t);const e=t,n=new Map;let r=0,i=0;const u=o(),c=[];let s=!0;function f(){const t=r;if(!s)return;if(t>=c.length)return void(s=!1);if("full"===l())return void(s=!1);!function(){if(!(i<e))throw Error();i++,m()}();const o=c[t];if(!o)throw Error();const[u,a]=o,h=Promise.resolve(Reflect.apply(u,void 0,a)),g=()=>{const e=n.get(t);if(!e)throw new Error;e.resolve(h),function(){if(i-1<0)throw Error();i--,m()}(),c[t]=void 0,n.delete(t)};h.then(g,g),r++,Promise.resolve().then(()=>{f()})}function l(){return i<e?"free":"full"}u.on("free",()=>{s=!0,f()}),u.on("full",()=>{s=!1});const a={[Symbol.toStringTag]:"AsyncCurrentLimiter",asyncwrap:function(t){return async function(...e){return await function(t){let e=c.length;c.push(t),"free"===l()&&(s=!0,f());const r=function(){let t=t=>{},e=t=>{};return{promise:new Promise((n,r)=>{t=n,e=r}),reject:e,resolve:t}}();return n.set(e,r),Promise.resolve(r.promise)}([t,e])}},status:l,limiter:{get max(){return e},get current(){return i}},queue:{get max(){return c.length},get current(){return r}},target:u};function m(){const{queue:t,limiter:n}=a,r={status:l(),queue:{max:t.max,current:t.current},limiter:{max:n.max,current:n.current}};i>=e?u.emit("full",r):u.emit("free",r)}return a}var u=(()=>{var t=new Function("return async()=>{}")()(),e=Symbol();function n(t){const e=i(t);return this&&this instanceof n?(Object.assign(this,e),this):Reflect.construct(n,[t])}return Reflect.set(n,e,t),n})();export default u;
+import e from"@masx200/event-emitter-target";function t(t){if(!("number"==typeof t&&t>0&&1/0>t))throw TypeError(" MAX expected: number;but invalid:"+t);const r=t,n=new Map;let o=0,u=0;const i=e(),s=[];let c=!0;function f(){const e=o;if(!c)return;if(e>=s.length)return void(c=!1);if("full"===a())return void(c=!1);!function(){if(!(u<r))throw Error();u++,h()}();const t=s[e];if(!t)throw Error();const[i,l]=t,m=Promise.resolve(Reflect.apply(i,void 0,l)),g=()=>{const t=n.get(e);if(!t)throw new Error;t.resolve(m),function(){if(u-1<0)throw Error();u--,h()}(),s[e]=void 0,n.delete(e)};m.then(g,g),o++,Promise.resolve().then((()=>{f()}))}function l(e){let t=s.length;s.push(e),"free"===a()&&(c=!0,f());const r=function(){let e=e=>{},t=e=>{};return{promise:new Promise(((r,n)=>{e=r,t=n})),reject:t,resolve:e}}();return n.set(t,r),Promise.resolve(r.promise)}function a(){return u<r?"free":"full"}i.on("free",(()=>{c=!0,f()})),i.on("full",(()=>{c=!1}));const m={[Symbol.toStringTag]:"AsyncCurrentLimiter",asyncwrap:function(e){return async function(){for(var t=arguments.length,r=new Array(t),n=0;n<t;n++)r[n]=arguments[n];return await l([e,r])}},status:a,limiter:{get max(){return r},get current(){return u}},queue:{get max(){return s.length},get current(){return o}},target:i};function h(){const{queue:e,limiter:t}=m,n={status:a(),queue:{max:e.max,current:e.current},limiter:{max:t.max,current:t.current}};u>=r?i.emit("full",n):i.emit("free",n)}return m}var r=(()=>{var e=new Function("return async()=>{}")()(),r=Symbol();function n(e){const r=t(e);return this&&this instanceof n?(Object.assign(this,r),this):Reflect.construct(n,[e])}return Reflect.set(n,r,e),n})();export{r as default};
 //# sourceMappingURL=index.min.js.map

package.json

 {
+    "files": [
+        "dist"
+    ],
+    "exports": {
+        ".": {
+            "require": "./dist/index.min.cjs",
+            "import": "./dist/index.js"
+        }
+    },
     "publishConfig": {
         "registry": "https://registry.npmjs.org/"
     },
-    "private": false,
-    "version": "1.0.9",
+    "version": "2.0.0",
     "types": "./dist/index.d.ts",
-    "main": "./dist/index.min.js",
-    "module": "./dist/index.min.js",
+    "main": "./dist/index.min.cjs",
+    "module": "./dist/index.js",
     "type": "module",
@@ -16,29 +24,31 @@ "name": "@masx200/async-task-current-limiter",
         "@babel/preset-env": "^7.9.0",
-        "@rollup/plugin-commonjs": "^11.0.2",
-        "@rollup/plugin-json": "^4.0.2",
-        "@rollup/plugin-node-resolve": "^7.1.1",
-        "@rollup/plugin-typescript": "^4.0.0",
+        "@rollup/plugin-babel": "^5.3.1",
+        "@rollup/plugin-commonjs": "^21.0.2",
+        "@rollup/plugin-json": "^4.1.0",
+        "@rollup/plugin-node-resolve": "^13.1.3",
+        "@rollup/plugin-typescript": "^8.3.1",
         "@types/node": "^13.9.8",
         "acorn": "^7.1.1",
+        "browserslist": "4.16.6",
         "live-server": "^1.2.1",
         "minimist": "^1.2.5",
         "prettier": "^2.0.5",
-        "rollup": "^2.3.1",
+        "rollup": "^2.70.1",
+        "rollup-external-modules": "^2.0.0",
         "rollup-plugin-babel": "^4.4.0",
-        "rollup-plugin-sourcemaps": "^0.5.0",
-        "rollup-plugin-terser": "^5.3.0",
-        "rollup-plugin-ts": "^1.2.23",
+        "rollup-plugin-sourcemaps": "^0.6.3",
+        "rollup-plugin-terser": "^7.0.2",
+        "rollup-plugin-ts": "^2.0.5",
+        "serialize-javascript": "4.0.0",
         "terser": "^4.6.10",
         "tslib": "^1.11.1",
-        "typescript": "^3.9.7",
-        "@rollup/plugin-babel": "^5.1.0"
+        "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@masx200/event-emitter-target": "^1.1.7"
+        "@masx200/event-emitter-target": "^2.0.0"
     },
     "license": "MIT",
     "scripts": {
-        "prettier": "prettier *.js --write *.json   *.md  ./**/*.ts",
-        "watch": "rollup --watch -c  rollup.config.js ",
-        "build": "rollup -c  rollup.config.js ",
+        "format": "prettier *.js --write *.json   *.md  ./**/*.ts *.mjs",
+        "build": "rollup -c  rollup.config.mjs ",
         "test": "node ./test/index.js"
@@ -49,3 +59,4 @@ },
     "description": "异步任务限流器 async-task-current-limiter",
-    "repository": "https://github.com/masx200/async-task-current-limiter"
+    "repository": "https://github.com/masx200/async-task-current-limiter",
+    "packageManager": "yarn@3.2.0"
 }

New alerts

Major refactor

Supply chain risk

Package 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

Uses eval

Supply chain risk

Package uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.

Found 1 instance in 1 package

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

40966

decreased by-34.33%

Dev dependency count

24

increased by14.29%

Number of package files

10

decreased by-65.52%

Lines of code

59

decreased by-89.37%

Number of low quality alerts

2

increased by100%

Number of medium supply chain risk alerts

4

increased byInfinity%

Dependency changes

• + Added@masx200/event-emitter-target@2.0.5(transitive)

• + Addedregenerator-runtime@0.13.11(transitive)

• - Removed@masx200/event-emitter-target@1.1.9(transitive)

• Updated@masx200/event-emitter-target@^2.0.0