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

Comparing version 1.0.8 to 1.0.9

dist/index.d.ts

@@ -34,2 +34,7 @@ type 空闲状态 = "free" | "full";
 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};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;
+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;
 //# 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};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;
+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;
 //# sourceMappingURL=index.min.js.map

package.json

@@ -6,3 +6,3 @@ {
     "private": false,
-    "version": "1.0.8",
+    "version": "1.0.9",
     "types": "./dist/index.d.ts",
@@ -14,3 +14,3 @@ "main": "./dist/index.min.js",
     "devDependencies": {
-        "@babel/core": "^7.9.0",
+        "@babel/core": "^7.11.1",
         "@babel/plugin-proposal-optional-catch-binding": "^7.8.3",
@@ -21,2 +21,3 @@ "@babel/preset-env": "^7.9.0",
         "@rollup/plugin-node-resolve": "^7.1.1",
+        "@rollup/plugin-typescript": "^4.0.0",
         "@types/node": "^13.9.8",
@@ -26,3 +27,3 @@ "acorn": "^7.1.1",
         "minimist": "^1.2.5",
-        "prettier": "^2.0.2",
+        "prettier": "^2.0.5",
         "rollup": "^2.3.1",
@@ -35,4 +36,4 @@ "rollup-plugin-babel": "^4.4.0",
         "tslib": "^1.11.1",
-        "typescript": "^3.8.3",
-        "@rollup/plugin-typescript": "^4.0.0"
+        "typescript": "^3.9.7",
+        "@rollup/plugin-babel": "^5.1.0"
     },
@@ -47,3 +48,3 @@ "dependencies": {
         "build": "rollup -c  rollup.config.js ",
-        "test": "live-server"
+        "test": "node ./test/index.js"
     },
@@ -50,0 +51,0 @@ "keywords": [],

rollup.config.js

@@ -1,2 +0,2 @@
-import babel from "rollup-plugin-babel";
+import babel from "@rollup/plugin-babel";
 // import sourcemaps from "rollup-plugin-sourcemaps";
@@ -3,0 +3,0 @@ import resolve from "@rollup/plugin-node-resolve";

src/createlimiter.ts

@@ -77,2 +77,3 @@ type FUNRETPRO<T> = (...arg: any[]) => Promise<T>;
             queue[index] = undefined;
+            cachepromise.delete(index);
         };
@@ -79,0 +80,0 @@ promise.then(settle, settle);

test/index.js

@@ -0,0 +0,0 @@ import limiterClass from "../dist/index.min.js";

tsconfig.json

@@ -13,3 +13,3 @@ {
         // "outDir": "./",
-        "sourceMap": true,
+        "sourceMap": false,
         "moduleResolution": "node",
@@ -16,0 +16,0 @@ "pretty": true,

No alert changes

Improved metrics

Total package byte prevSize

62384

increased by5.34%

Number of package files

29

increased by7.41%

Lines of code

555

increased by1.09%

Worsened metrics

Dev dependency count

21

increased by5%

No dependency changes