async-manager-promise - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

build/index.js

 import AsyncManager from 'async-manager';
+const errCbToPromiseExecutor = (resolve, reject) => (err, data) => {
+    if (err) {
+        reject(err);
+    }
+    else {
+        resolve(data);
+    }
+};
 class AsyncManagerPromise {
@@ -8,10 +16,4 @@ constructor() {
         const promise = new Promise(async (resolve, reject) => {
-            this.manager.add(id, (err, data) => {
-                if (err) {
-                    reject(err);
-                }
-                else {
-                    resolve(data);
-                }
-            });
+            const cb = errCbToPromiseExecutor(resolve, reject);
+            this.manager.add(id, cb);
         });
@@ -21,4 +23,5 @@ return promise;
     getPromiseWithId(onInit) {
-        const promise = new Promise(async (resolve) => {
-            const id = this.manager.addAndGetId(resolve);
+        const promise = new Promise(async (resolve, reject) => {
+            const cb = errCbToPromiseExecutor(resolve, reject);
+            const id = this.manager.addAndGetId(cb);
             if (onInit) {
@@ -25,0 +28,0 @@ onInit(id);

package.json

 {
   "name": "async-manager-promise",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "TODO",
@@ -5,0 +5,0 @@ "main": "./build/index.js",

src/index.ts

 import AsyncManager from 'async-manager'
 
+const errCbToPromiseExecutor = (resolve, reject) =>
+  (err, data) => {
+    if (err) {
+      reject(err)
+    } else {
+      resolve(data)
+    }
+  }
+
 class AsyncManagerPromise<OutputType, Id = any> {
@@ -8,9 +17,4 @@ protected manager = new AsyncManager<OutputType, Id>()
     const promise = new Promise<OutputType>(async (resolve, reject) => {
-      this.manager.add(id, (err, data) => {
-        if (err) {
-          reject(err)
-        } else {
-          resolve(data)
-        }
-      })
+      const cb = errCbToPromiseExecutor(resolve, reject)
+      this.manager.add(id, cb)
     })
@@ -22,4 +26,6 @@
   getPromiseWithId(onInit?: (id: string) => void) {
-    const promise = new Promise<OutputType>(async (resolve) => {
-      const id = this.manager.addAndGetId(resolve)
+    const promise = new Promise<OutputType>(async (resolve, reject) => {
+      const cb = errCbToPromiseExecutor(resolve, reject)
+      const id = this.manager.addAndGetId(cb)
+
       if (onInit) {
@@ -26,0 +32,0 @@ onInit(id)

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

5864

increased by8.17%

Lines of code

112

increased by6.67%

No dependency changes