diff options
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js')
-rw-r--r-- | cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js b/cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js deleted file mode 100644 index 54fbe9e89..000000000 --- a/cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js +++ /dev/null @@ -1,43 +0,0 @@ -// deno-fmt-ignore-file -// deno-lint-ignore-file - -// Copyright Joyent and Node contributors. All rights reserved. MIT license. -// Taken from Node 18.12.1 -// This file is automatically generated by `tools/node_compat/setup.ts`. Do not modify this file manually. - -'use strict'; -const common = require('../common'); -const stream = require('stream'); -const assert = require('assert'); - -const writable = new stream.Writable({ - write: common.mustCall(function(chunk, encoding, cb) { - assert.strictEqual( - readable._readableState.awaitDrainWriters, - null, - ); - - if (chunk.length === 32 * 1024) { // first chunk - readable.push(Buffer.alloc(34 * 1024)); // above hwm - // We should check if awaitDrain counter is increased in the next - // tick, because awaitDrain is incremented after this method finished - process.nextTick(() => { - assert.strictEqual(readable._readableState.awaitDrainWriters, writable); - }); - } - - process.nextTick(cb); - }, 3) -}); - -// A readable stream which produces two buffers. -const bufs = [Buffer.alloc(32 * 1024), Buffer.alloc(33 * 1024)]; // above hwm -const readable = new stream.Readable({ - read: function() { - while (bufs.length > 0) { - this.push(bufs.shift()); - } - } -}); - -readable.pipe(writable); |