github/node-v0.x-archive
1
1
Fork 0
mirror of https://github.com/nodejs/node-v0.x-archive.git synced 2026-04-28 03:01:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

streams2: NextTick the emit('readable') in resume()

Browse Source 
Otherwise resume() will cause data to be emitted before it can be handled.
This commit is contained in:
isaacs
2012-12-04 18:19:07 -08:00
parent 99021b7a4f
commit dbcacc5afe
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/_stream_readable.js
View File

@@ -545,6 +545,7 @@ function emitDataEvents(stream, startPaused) {
stream.on('readable', function() {
readable = true;
var c;
while (!paused && (null !== (c = stream.read())))
stream.emit('data', c);
@@ -562,7 +563,9 @@ function emitDataEvents(stream, startPaused) {
stream.resume = function() {
paused = false;
if (readable)
stream.emit('readable');
process.nextTick(function() {
stream.emit('readable');
});
};
// now make it start, just in case it hadn't already.