Comparing version 0.7.0dev to 0.7.1
@@ -0,0 +0,0 @@ # Changelog |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../index').flow; |
@@ -0,0 +0,0 @@ var flow = require('../../index').flow; |
'use strict'; | ||
exports.name = 'nue'; | ||
exports.version = '0.7.0dev'; | ||
exports.version = '0.7.1'; | ||
exports.flow = flow; | ||
@@ -37,5 +37,5 @@ exports.parallel = parallel; | ||
var location = getLocation(startFlow); | ||
debug('begin TOP_LEVEL_FLOW. flow: %s(%d), calledAt: %s:%d:%d, args:', | ||
flow.flowName || '<anonymous>', flow.flowId, | ||
location.fileName, location.lineNumber, location.columnNumber, | ||
debug('begin TOP_LEVEL_FLOW. flow: %s(%d), calledAt: %s:%d:%d, args:', | ||
flow.flowName || '<anonymous>', flow.flowId, | ||
location.fileName, location.lineNumber, location.columnNumber, | ||
Array.prototype.slice.call(arguments)); | ||
@@ -106,6 +106,6 @@ } | ||
} | ||
function runStep(step, context, args) { | ||
if (debugMode) { | ||
debug('begin STEP. flow: %s(%d), step: %s(%d), args:', | ||
debug('begin STEP. flow: %s(%d), step: %s(%d), args:', | ||
context.flowName || '<anonymous>', context._flow.flowId, | ||
@@ -290,3 +290,3 @@ context.stepName || '<anonymous>', context.stepIndex, Array.prototype.slice.call(args)); | ||
for (var i = 0; i < concurrency && index < len; i++, index++) { | ||
worker.call(self, array[index], group, index, array); | ||
worker.call(self, array[index], group, index, array); | ||
} | ||
@@ -425,3 +425,3 @@ if (index === len) { | ||
e.asyncCallHistory = history; | ||
e.message += util.format('\ncause stack is ...\n %s\nasync call history is ...\n', | ||
e.message += util.format('\ncause stack is ...\n %s\nasync call history is ...\n', | ||
e.cause.stack, history); | ||
@@ -428,0 +428,0 @@ return e; |
@@ -9,6 +9,7 @@ { | ||
"main" : "./lib/nue.js", | ||
"devDependencies": { | ||
"mocha": "~0.11.0" | ||
"devDependencies": { | ||
"mocha": "~2.2.1" | ||
}, | ||
"version" : "0.7.0dev" | ||
"version" : "0.7.1", | ||
"scripts": { "test" : "mocha test" } | ||
} |
@@ -206,3 +206,3 @@ nue — An async control-flow library | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -230,3 +230,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -258,3 +258,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -297,3 +297,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -329,3 +329,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -451,3 +451,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -483,3 +483,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -518,3 +518,3 @@ | ||
var flow = require('nue').flow; | ||
var as = require('as').as; | ||
var as = require('nue').as; | ||
var fs = require('fs'); | ||
@@ -595,2 +595,2 @@ | ||
30 | ||
``` | ||
``` |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
588
39146