summaryrefslogtreecommitdiff
path: root/cli/tests/node_compat/test/parallel/test-stream-backpressure.js
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-backpressure.js')
-rw-r--r--cli/tests/node_compat/test/parallel/test-stream-backpressure.js46
1 files changed, 0 insertions, 46 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-backpressure.js b/cli/tests/node_compat/test/parallel/test-stream-backpressure.js
deleted file mode 100644
index f1e14bb5d..000000000
--- a/cli/tests/node_compat/test/parallel/test-stream-backpressure.js
+++ /dev/null
@@ -1,46 +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 assert = require('assert');
-const stream = require('stream');
-
-let pushes = 0;
-const total = 65500 + 40 * 1024;
-const rs = new stream.Readable({
- read: common.mustCall(function() {
- if (pushes++ === 10) {
- this.push(null);
- return;
- }
-
- const length = this._readableState.length;
-
- // We are at most doing two full runs of _reads
- // before stopping, because Readable is greedy
- // to keep its buffer full
- assert(length <= total);
-
- this.push(Buffer.alloc(65500));
- for (let i = 0; i < 40; i++) {
- this.push(Buffer.alloc(1024));
- }
-
- // We will be over highWaterMark at this point
- // but a new call to _read is scheduled anyway.
- }, 11)
-});
-
-const ws = stream.Writable({
- write: common.mustCall(function(data, enc, cb) {
- setImmediate(cb);
- }, 41 * 10)
-});
-
-rs.pipe(ws);