diff options
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-auto-destroy.js')
-rw-r--r-- | cli/tests/node_compat/test/parallel/test-stream-auto-destroy.js | 119 |
1 files changed, 0 insertions, 119 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-auto-destroy.js b/cli/tests/node_compat/test/parallel/test-stream-auto-destroy.js deleted file mode 100644 index a0947ba39..000000000 --- a/cli/tests/node_compat/test/parallel/test-stream-auto-destroy.js +++ /dev/null @@ -1,119 +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'); -const assert = require('assert'); - -{ - const r = new stream.Readable({ - autoDestroy: true, - read() { - this.push('hello'); - this.push('world'); - this.push(null); - }, - destroy: common.mustCall((err, cb) => cb()) - }); - - let ended = false; - - r.resume(); - - r.on('end', common.mustCall(() => { - ended = true; - })); - - r.on('close', common.mustCall(() => { - assert(ended); - })); -} - -{ - const w = new stream.Writable({ - autoDestroy: true, - write(data, enc, cb) { - cb(null); - }, - destroy: common.mustCall((err, cb) => cb()) - }); - - let finished = false; - - w.write('hello'); - w.write('world'); - w.end(); - - w.on('finish', common.mustCall(() => { - finished = true; - })); - - w.on('close', common.mustCall(() => { - assert(finished); - })); -} - -{ - const t = new stream.Transform({ - autoDestroy: true, - transform(data, enc, cb) { - cb(null, data); - }, - destroy: common.mustCall((err, cb) => cb()) - }); - - let ended = false; - let finished = false; - - t.write('hello'); - t.write('world'); - t.end(); - - t.resume(); - - t.on('end', common.mustCall(() => { - ended = true; - })); - - t.on('finish', common.mustCall(() => { - finished = true; - })); - - t.on('close', common.mustCall(() => { - assert(ended); - assert(finished); - })); -} - -{ - const r = new stream.Readable({ - read() { - r2.emit('error', new Error('fail')); - } - }); - const r2 = new stream.Readable({ - autoDestroy: true, - destroy: common.mustCall((err, cb) => cb()) - }); - - r.pipe(r2); -} - -{ - const r = new stream.Readable({ - read() { - w.emit('error', new Error('fail')); - } - }); - const w = new stream.Writable({ - autoDestroy: true, - destroy: common.mustCall((err, cb) => cb()) - }); - - r.pipe(w); -} |