event-stream
Advanced tools
Comparing version 3.1.4 to 3.1.5
@@ -16,2 +16,3 @@ //filter will reemit the data if cb(err,pass) pass is truthy | ||
, pipeline = require('stream-combiner') | ||
, immediately = global.setImmediate || process.nextTick; | ||
@@ -156,3 +157,3 @@ es.Stream = Stream //re-export Stream from core | ||
process.nextTick(function () { | ||
immediately(function () { | ||
if(ended || paused || reading) return | ||
@@ -159,0 +160,0 @@ try { |
{ | ||
"name": "event-stream", | ||
"version": "3.1.4", | ||
"version": "3.1.5", | ||
"description": "construct pipes of streams of events", | ||
@@ -5,0 +5,0 @@ "homepage": "http://github.com/dominictarr/event-stream", |
@@ -26,3 +26,3 @@ | ||
it(array).deepEqual(readThis) | ||
test.done() | ||
test.done() | ||
}) | ||
@@ -121,3 +121,25 @@ | ||
exports ['does not raise a warning: Recursive process.nextTick detected'] = function (test) { | ||
var readThisDelayed; | ||
u.delay(function () { | ||
readThisDelayed = [1, 3, 5]; | ||
})(); | ||
es.readable(function (count, callback) { | ||
if (readThisDelayed) { | ||
var that = this; | ||
readThisDelayed.forEach(function (item) { | ||
that.emit('data', item); | ||
}); | ||
this.emit('end'); | ||
test.done(); | ||
} | ||
callback(); | ||
}); | ||
}; | ||
// | ||
@@ -124,0 +146,0 @@ // emitting multiple errors is not supported by stream. |
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
41782
1103