summaryrefslogtreecommitdiff
path: root/cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js')
-rw-r--r--cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js92
1 files changed, 0 insertions, 92 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js b/cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js
deleted file mode 100644
index d0b60f435..000000000
--- a/cli/tests/node_compat/test/parallel/test-stream-unpipe-event.js
+++ /dev/null
@@ -1,92 +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 { Writable, Readable } = require('stream');
-class NullWriteable extends Writable {
- _write(chunk, encoding, callback) {
- return callback();
- }
-}
-class QuickEndReadable extends Readable {
- _read() {
- this.push(null);
- }
-}
-class NeverEndReadable extends Readable {
- _read() {}
-}
-
-{
- const dest = new NullWriteable();
- const src = new QuickEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustCall());
- src.pipe(dest);
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 0);
- });
-}
-
-{
- const dest = new NullWriteable();
- const src = new NeverEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustNotCall('unpipe should not have been emitted'));
- src.pipe(dest);
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 1);
- });
-}
-
-{
- const dest = new NullWriteable();
- const src = new NeverEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustCall());
- src.pipe(dest);
- src.unpipe(dest);
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 0);
- });
-}
-
-{
- const dest = new NullWriteable();
- const src = new QuickEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustCall());
- src.pipe(dest, { end: false });
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 0);
- });
-}
-
-{
- const dest = new NullWriteable();
- const src = new NeverEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustNotCall('unpipe should not have been emitted'));
- src.pipe(dest, { end: false });
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 1);
- });
-}
-
-{
- const dest = new NullWriteable();
- const src = new NeverEndReadable();
- dest.on('pipe', common.mustCall());
- dest.on('unpipe', common.mustCall());
- src.pipe(dest, { end: false });
- src.unpipe(dest);
- setImmediate(() => {
- assert.strictEqual(src._readableState.pipes.length, 0);
- });
-}