diff options
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js')
-rw-r--r-- | cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js | 42 |
1 files changed, 0 insertions, 42 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js b/cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js deleted file mode 100644 index 0666e44d6..000000000 --- a/cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js +++ /dev/null @@ -1,42 +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'); - -function test(throwCodeInbetween) { - // Check that a pipe does not stall if .read() is called unexpectedly - // (i.e. the stream is not resumed by the pipe). - - const n = 1000; - let counter = n; - const rs = stream.Readable({ - objectMode: true, - read: common.mustCallAtLeast(() => { - if (--counter >= 0) - rs.push({ counter }); - else - rs.push(null); - }, n) - }); - - const ws = stream.Writable({ - objectMode: true, - write: common.mustCall((data, enc, cb) => { - setImmediate(cb); - }, n) - }); - - setImmediate(() => throwCodeInbetween(rs, ws)); - - rs.pipe(ws); -} - -test((rs) => rs.read()); -test((rs) => rs.resume()); -test(() => 0); |