summaryrefslogtreecommitdiff
path: root/cli/tests/node_compat/test/parallel/test-stream-pipe-await-drain-push-while-write.js
diff options
context:
space:
mode:
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.js43
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);