stream: simplify src._readableState
to state
PR-URL: https://github.com/nodejs/node/pull/18264 Reviewed-By: Weijia Wang <starkwang@126.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Michaël Zasso <targos@protonmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
This commit is contained in:
parent
7f6a3bad0f
commit
49b3798f81
@ -649,8 +649,8 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
|
|||||||
if (((state.pipesCount === 1 && state.pipes === dest) ||
|
if (((state.pipesCount === 1 && state.pipes === dest) ||
|
||||||
(state.pipesCount > 1 && state.pipes.indexOf(dest) !== -1)) &&
|
(state.pipesCount > 1 && state.pipes.indexOf(dest) !== -1)) &&
|
||||||
!cleanedUp) {
|
!cleanedUp) {
|
||||||
debug('false write response, pause', src._readableState.awaitDrain);
|
debug('false write response, pause', state.awaitDrain);
|
||||||
src._readableState.awaitDrain++;
|
state.awaitDrain++;
|
||||||
increasedAwaitDrain = true;
|
increasedAwaitDrain = true;
|
||||||
}
|
}
|
||||||
src.pause();
|
src.pause();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user