Comparing version 0.0.6 to 0.0.7
@@ -18,3 +18,2 @@ //filter will reemit the data if cb(err,pass) pass is truthy | ||
var stream = new Stream() | ||
, self = this | ||
, inputs = 0 | ||
@@ -28,4 +27,4 @@ , outputs = 0 | ||
this.opts = opts || {}; | ||
var errorEventName = this.opts.failures ? 'failure' : 'error'; | ||
opts = opts || {}; | ||
var errorEventName = opts.failures ? 'failure' : 'error'; | ||
@@ -72,3 +71,3 @@ // Items that are not ready to be written yet (because they would come out of | ||
if (!err || self.opts.failures) { | ||
if (!err || opts.failures) { | ||
queueData(data, number) | ||
@@ -75,0 +74,0 @@ } |
{ | ||
"name": "map-stream", | ||
"version": "0.0.6", | ||
"version": "0.0.7", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "description": "construct pipes of streams of events", |
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
13614
8
377