highland-process
Advanced tools
Comparing version 1.0.2 to 1.0.3
@@ -13,9 +13,12 @@ var _ = require('highland'), | ||
return function(stream) { | ||
var errors = _(); | ||
var errors, | ||
errorsToResults, | ||
out = exports.from(process); | ||
stream | ||
.consume(errorsTo(errors)) | ||
.pipe(process.stdin); | ||
errorsToResults = errorsTo(stream); | ||
stream = errorsToResults.stream; | ||
errors = errorsToResults.errors; | ||
stream.pipe(process.stdin); | ||
return _.sequence([ | ||
@@ -64,4 +67,3 @@ out, | ||
} | ||
push(null, _.nil); | ||
return next(); | ||
return push(null, _.nil); | ||
} | ||
@@ -68,0 +70,0 @@ |
{ | ||
"name": "highland-process", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "Utility that lets you turn a process into a highland stream.", | ||
@@ -30,4 +30,4 @@ "main": "index.js", | ||
"highland": "^2.2.0", | ||
"highland-errors-to": "^1.0.0" | ||
"highland-errors-to": "^2.0.0" | ||
} | ||
} |
5393
143
+ Addedhighland-errors-to@2.0.1(transitive)
- Removedhighland-errors-to@1.0.1(transitive)
Updatedhighland-errors-to@^2.0.0