diff options
| author | ran <abbshrsoufii@gmail.com> | 2019-08-26 17:00:06 +0800 |
|---|---|---|
| committer | Anna Henningsen <anna@addaleax.net> | 2019-08-26 15:20:50 +0200 |
| commit | 698a29420f92844478101ec1fccdc81b46954e2e (patch) | |
| tree | 47e4f9c728981a0e9377d622a957632c39ccf61c /test/parallel/test-stream-pipe-await-drain.js | |
| parent | 627bf59e8ddd9826720c45f430c2a2e489df6e66 (diff) | |
| download | android-node-v8-698a29420f92844478101ec1fccdc81b46954e2e.tar.gz android-node-v8-698a29420f92844478101ec1fccdc81b46954e2e.tar.bz2 android-node-v8-698a29420f92844478101ec1fccdc81b46954e2e.zip | |
stream: fix readable state `awaitDrain` increase in recursion
PR-URL: https://github.com/nodejs/node/pull/27572
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Diffstat (limited to 'test/parallel/test-stream-pipe-await-drain.js')
| -rw-r--r-- | test/parallel/test-stream-pipe-await-drain.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/test/parallel/test-stream-pipe-await-drain.js b/test/parallel/test-stream-pipe-await-drain.js index 9286ceb791..3ae248e08b 100644 --- a/test/parallel/test-stream-pipe-await-drain.js +++ b/test/parallel/test-stream-pipe-await-drain.js @@ -24,10 +24,10 @@ writer1._write = common.mustCall(function(chunk, encoding, cb) { writer1.once('chunk-received', () => { assert.strictEqual( - reader._readableState.awaitDrain, + reader._readableState.awaitDrainWriters.size, 0, 'awaitDrain initial value should be 0, actual is ' + - reader._readableState.awaitDrain + reader._readableState.awaitDrainWriters ); setImmediate(() => { // This one should *not* get through to writer1 because writer2 is not @@ -39,10 +39,10 @@ writer1.once('chunk-received', () => { // A "slow" consumer: writer2._write = common.mustCall((chunk, encoding, cb) => { assert.strictEqual( - reader._readableState.awaitDrain, + reader._readableState.awaitDrainWriters.size, 1, 'awaitDrain should be 1 after first push, actual is ' + - reader._readableState.awaitDrain + reader._readableState.awaitDrainWriters ); // Not calling cb here to "simulate" slow stream. // This should be called exactly once, since the first .write() call @@ -51,10 +51,10 @@ writer2._write = common.mustCall((chunk, encoding, cb) => { writer3._write = common.mustCall((chunk, encoding, cb) => { assert.strictEqual( - reader._readableState.awaitDrain, + reader._readableState.awaitDrainWriters.size, 2, 'awaitDrain should be 2 after second push, actual is ' + - reader._readableState.awaitDrain + reader._readableState.awaitDrainWriters ); // Not calling cb here to "simulate" slow stream. // This should be called exactly once, since the first .write() call |