flowa - npm Package Compare versions

Comparing version 3.4.0 to 3.4.1

index.js

@@ -339,3 +339,3 @@ /**
 
-    task = task.bind(new FlowaTask(taskName, runVariables, self));
+    task = task.bind(new FlowaTask(taskName, callback, runVariables, self));
 
@@ -505,3 +505,3 @@ returnedValue = self._timeout(task, timeout, runVariables, taskName)(runVariables.context, callback);
  */
-function FlowaTask(taskName, runVariables, flowa) {
+function FlowaTask(taskName, callback, runVariables, flowa) {
 
@@ -515,2 +515,8 @@ /**
   /**
+   * The task's callback
+   * @type {Function}
+   */
+  this.callback = callback;
+
+  /**
    * Variables needed for the current run
@@ -542,3 +548,3 @@ * @type {Object}
 /**
- * Set the execution as terminated
+ * Set the execution as terminated and call the task's callback
  */
@@ -548,2 +554,3 @@ FlowaTask.prototype.done = function() {
   this._runVariables.terminated = true;
+  this.callback();
   
@@ -550,0 +557,0 @@ };

package.json

 {
   "name": "flowa",
-  "version": "3.4.0",
+  "version": "3.4.1",
   "description": "Service level control flow for Node.js",
@@ -5,0 +5,0 @@ "main": "index.js",

test/helpers/generators.js

@@ -130,4 +130,3 @@ /**
     context['task' + id] = context['task' + id] ? context['task' + id] + 1 : 1;
-    this.done();
-    setImmediate(callback);
+    setImmediate(this.done.bind(this));
   };
@@ -134,0 +133,0 @@

No alert changes

Improved metrics

Total package byte prevSize

245060

increased by0.06%

Lines of code

3195

increased by0.16%

No dependency changes