Increase pool.used before making 'data' event
This commit is contained in:
parent
a49bf8622f
commit
7ed80451ca
@ -295,7 +295,7 @@ function initStream (self) {
|
|||||||
|
|
||||||
debug('bytesRead ' + bytesRead + '\n');
|
debug('bytesRead ' + bytesRead + '\n');
|
||||||
|
|
||||||
if (bytesRead == 0) {
|
if (bytesRead === 0) {
|
||||||
self.readable = false;
|
self.readable = false;
|
||||||
self._readWatcher.stop();
|
self._readWatcher.stop();
|
||||||
|
|
||||||
@ -309,6 +309,7 @@ function initStream (self) {
|
|||||||
|
|
||||||
var start = pool.used;
|
var start = pool.used;
|
||||||
var end = pool.used + bytesRead;
|
var end = pool.used + bytesRead;
|
||||||
|
pool.used += bytesRead;
|
||||||
|
|
||||||
if (!self._encoding) {
|
if (!self._encoding) {
|
||||||
if (self._events && self._events['data']) {
|
if (self._events && self._events['data']) {
|
||||||
@ -337,9 +338,6 @@ function initStream (self) {
|
|||||||
}
|
}
|
||||||
self.emit('data', string);
|
self.emit('data', string);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
pool.used += bytesRead;
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
self.readable = false;
|
self.readable = false;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user