async-queue-improved - npm Package Compare versions

Comparing version 0.0.5 to 0.0.6

index.js

@@ -12,2 +12,15 @@ var async = require('async'),
 
+    var retryCallback = function(err) {
+      if (!err) return callback.apply(null, arguments)
+      if (!task.retries) return callback(err)
+
+      // console.error(err.stack || err)
+      task.attempts = task.attempts || 0
+      task.attempts++
+
+      if (task.attempts <= task.retries) {
+        queue.push(task, callback)
+      }
+    }
+
     // Set timeout for the task execution
@@ -22,3 +35,3 @@ var timeout = setTimeout(function() {
       // pass the error to a callback
-      callback(err)
+      retryCallback(err)
     }, task.timeout)
@@ -39,3 +52,3 @@
         setImmediate(function(){
-          callback(err, result)
+          retryCallback(err, result)
         })
@@ -42,0 +55,0 @@ }

package.json

 {
   "name": "async-queue-improved",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "description": "Improved queue based `async` package",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

5114

increased by7.35%

Lines of code

135

increased by8%

No dependency changes