node-pipeline
Advanced tools
Comparing version 0.4.1 to 0.5.0
@@ -36,7 +36,7 @@ var _ = require("lodash"), | ||
this.on('step', function(name, action) { | ||
process.nextTick(action); | ||
}) | ||
setImmediate(action); | ||
}); | ||
this.on('next', function(err, params) { | ||
process.nextTick( _.bind(that.execute, that, err, params) ); | ||
that.execute(err, params); | ||
}); | ||
@@ -106,3 +106,3 @@ }; | ||
this.currentStep++; | ||
this.emit('step', step.name, action); | ||
this.emit('step', { pipeline: this, step: step.name }, action); | ||
@@ -109,0 +109,0 @@ return this; |
{ | ||
"name": "node-pipeline", | ||
"version": "0.4.1", | ||
"version": "0.5.0", | ||
"main": "index", | ||
@@ -34,3 +34,3 @@ "description": "Simple module to performing asynchronous inter-dependent series operations in node. Unlike other more complicated approaches, this is pure javascript and very small (~100 lines of code with comments).", | ||
"dependencies": { | ||
"lodash": "0.8.2" | ||
"lodash": "1.2.1" | ||
}, | ||
@@ -37,0 +37,0 @@ "devDependencies": { |
@@ -11,4 +11,4 @@ var _ = require('lodash'), | ||
// add logging with event emitter | ||
pl.on('step', function(name) { | ||
console.log("Executing step - " + pl.name + ":" + name); | ||
pl.on('step', function(data) { | ||
console.log("Executing step - " + data.pipeline.name + ":" + data.step); | ||
}) | ||
@@ -15,0 +15,0 @@ |
Sorry, the diff of this file is not supported yet
12086
+ Addedlodash@1.2.1(transitive)
- Removedlodash@0.8.2(transitive)
Updatedlodash@1.2.1