summaryrefslogtreecommitdiff
path: root/cli/tests/node_compat/test/parallel/test-stream-pipe-manual-resume.js
diff options
context:
space:
mode:
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.js42
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);