|
|
@ -524,10 +524,12 @@ Readable.prototype.addListener = Readable.prototype.on; |
|
|
|
Readable.prototype.resume = function() { |
|
|
|
emitDataEvents(this); |
|
|
|
this.read(0); |
|
|
|
this.emit('resume'); |
|
|
|
}; |
|
|
|
|
|
|
|
Readable.prototype.pause = function() { |
|
|
|
emitDataEvents(this, true); |
|
|
|
this.emit('pause'); |
|
|
|
}; |
|
|
|
|
|
|
|
function emitDataEvents(stream, startPaused) { |
|
|
@ -561,6 +563,7 @@ function emitDataEvents(stream, startPaused) { |
|
|
|
|
|
|
|
stream.pause = function() { |
|
|
|
paused = true; |
|
|
|
this.emit('pause'); |
|
|
|
}; |
|
|
|
|
|
|
|
stream.resume = function() { |
|
|
@ -571,6 +574,7 @@ function emitDataEvents(stream, startPaused) { |
|
|
|
}); |
|
|
|
else |
|
|
|
this.read(0); |
|
|
|
this.emit('resume'); |
|
|
|
}; |
|
|
|
|
|
|
|
// now make it start, just in case it hadn't already.
|
|
|
|