diff options
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.js | 46 |
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); |