summaryrefslogtreecommitdiff
path: root/cli/tests/node_compat/test/parallel/test-stream-construct.js
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-construct.js')
-rw-r--r--cli/tests/node_compat/test/parallel/test-stream-construct.js287
1 files changed, 0 insertions, 287 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-construct.js b/cli/tests/node_compat/test/parallel/test-stream-construct.js
deleted file mode 100644
index 0cd93c9e9..000000000
--- a/cli/tests/node_compat/test/parallel/test-stream-construct.js
+++ /dev/null
@@ -1,287 +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 { Writable, Readable, Duplex } = require('stream');
-const assert = require('assert');
-
-{
- // Multiple callback.
- new Writable({
- construct: common.mustCall((callback) => {
- callback();
- callback();
- })
- }).on('error', common.expectsError({
- name: 'Error',
- code: 'ERR_MULTIPLE_CALLBACK'
- }));
-}
-
-{
- // Multiple callback.
- new Readable({
- construct: common.mustCall((callback) => {
- callback();
- callback();
- })
- }).on('error', common.expectsError({
- name: 'Error',
- code: 'ERR_MULTIPLE_CALLBACK'
- }));
-}
-
-{
- // Synchronous error.
-
- new Writable({
- construct: common.mustCall((callback) => {
- callback(new Error('test'));
- })
- }).on('error', common.expectsError({
- name: 'Error',
- message: 'test'
- }));
-}
-
-{
- // Synchronous error.
-
- new Readable({
- construct: common.mustCall((callback) => {
- callback(new Error('test'));
- })
- }).on('error', common.expectsError({
- name: 'Error',
- message: 'test'
- }));
-}
-
-{
- // Asynchronous error.
-
- new Writable({
- construct: common.mustCall((callback) => {
- process.nextTick(callback, new Error('test'));
- })
- }).on('error', common.expectsError({
- name: 'Error',
- message: 'test'
- }));
-}
-
-{
- // Asynchronous error.
-
- new Readable({
- construct: common.mustCall((callback) => {
- process.nextTick(callback, new Error('test'));
- })
- }).on('error', common.expectsError({
- name: 'Error',
- message: 'test'
- }));
-}
-
-function testDestroy(factory) {
- {
- let constructed = false;
- const s = factory({
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- })
- });
- s.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.destroy();
- }
-
- {
- let constructed = false;
- const s = factory({
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- })
- });
- s.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.destroy(null, () => {
- assert.strictEqual(constructed, true);
- });
- }
-
- {
- let constructed = false;
- const s = factory({
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- })
- });
- s.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.destroy();
- }
-
-
- {
- let constructed = false;
- const s = factory({
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- })
- });
- s.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.on('error', common.mustCall((err) => {
- assert.strictEqual(err.message, 'kaboom');
- }));
- s.destroy(new Error('kaboom'), (err) => {
- assert.strictEqual(err.message, 'kaboom');
- assert.strictEqual(constructed, true);
- });
- }
-
- {
- let constructed = false;
- const s = factory({
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- })
- });
- s.on('error', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- s.destroy(new Error());
- }
-}
-testDestroy((opts) => new Readable({
- read: common.mustNotCall(),
- ...opts
-}));
-testDestroy((opts) => new Writable({
- write: common.mustNotCall(),
- final: common.mustNotCall(),
- ...opts
-}));
-
-{
- let constructed = false;
- const r = new Readable({
- autoDestroy: true,
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- }),
- read: common.mustCall(() => {
- assert.strictEqual(constructed, true);
- r.push(null);
- })
- });
- r.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- r.on('data', common.mustNotCall());
-}
-
-{
- let constructed = false;
- const w = new Writable({
- autoDestroy: true,
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- }),
- write: common.mustCall((chunk, encoding, cb) => {
- assert.strictEqual(constructed, true);
- process.nextTick(cb);
- }),
- final: common.mustCall((cb) => {
- assert.strictEqual(constructed, true);
- process.nextTick(cb);
- })
- });
- w.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- w.end('data');
-}
-
-{
- let constructed = false;
- const w = new Writable({
- autoDestroy: true,
- construct: common.mustCall((cb) => {
- constructed = true;
- process.nextTick(cb);
- }),
- write: common.mustNotCall(),
- final: common.mustCall((cb) => {
- assert.strictEqual(constructed, true);
- process.nextTick(cb);
- })
- });
- w.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
- w.end();
-}
-
-{
- new Duplex({
- construct: common.mustCall()
- });
-}
-
-{
- // https://github.com/nodejs/node/issues/34448
-
- let constructed = false;
- const d = new Duplex({
- readable: false,
- construct: common.mustCall((callback) => {
- setImmediate(common.mustCall(() => {
- constructed = true;
- callback();
- }));
- }),
- write(chunk, encoding, callback) {
- callback();
- },
- read() {
- this.push(null);
- }
- });
- d.resume();
- d.end('foo');
- d.on('close', common.mustCall(() => {
- assert.strictEqual(constructed, true);
- }));
-}
-
-{
- // Construct should not cause stream to read.
- new Readable({
- construct: common.mustCall((callback) => {
- callback();
- }),
- read: common.mustNotCall()
- });
-}