Skip to content

Commit 25bebae

Browse files
陈刚evanlucas
陈刚
authored andcommitted
stream: simplify src._readableState to state
PR-URL: #18264 Reviewed-By: Weijia Wang <[email protected]> Reviewed-By: Luigi Pinca <[email protected]> Reviewed-By: Michaël Zasso <[email protected]> Reviewed-By: Matteo Collina <[email protected]>
1 parent 117b20e commit 25bebae

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/_stream_readable.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -652,8 +652,8 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
652652
if (((state.pipesCount === 1 && state.pipes === dest) ||
653653
(state.pipesCount > 1 && state.pipes.indexOf(dest) !== -1)) &&
654654
!cleanedUp) {
655-
debug('false write response, pause', src._readableState.awaitDrain);
656-
src._readableState.awaitDrain++;
655+
debug('false write response, pause', state.awaitDrain);
656+
state.awaitDrain++;
657657
increasedAwaitDrain = true;
658658
}
659659
src.pause();

0 commit comments

Comments
 (0)