diff options
Diffstat (limited to 'cli/tests/node_compat/test/parallel/test-stream-pipe-cleanup.js')
-rw-r--r-- | cli/tests/node_compat/test/parallel/test-stream-pipe-cleanup.js | 132 |
1 files changed, 0 insertions, 132 deletions
diff --git a/cli/tests/node_compat/test/parallel/test-stream-pipe-cleanup.js b/cli/tests/node_compat/test/parallel/test-stream-pipe-cleanup.js deleted file mode 100644 index 8106ab4f1..000000000 --- a/cli/tests/node_compat/test/parallel/test-stream-pipe-cleanup.js +++ /dev/null @@ -1,132 +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. - -// Copyright Joyent, Inc. and other Node contributors. -// -// Permission is hereby granted, free of charge, to any person obtaining a -// copy of this software and associated documentation files (the -// "Software"), to deal in the Software without restriction, including -// without limitation the rights to use, copy, modify, merge, publish, -// distribute, sublicense, and/or sell copies of the Software, and to permit -// persons to whom the Software is furnished to do so, subject to the -// following conditions: -// -// The above copyright notice and this permission notice shall be included -// in all copies or substantial portions of the Software. -// -// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS -// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF -// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN -// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, -// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR -// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE -// USE OR OTHER DEALINGS IN THE SOFTWARE. - -'use strict'; -// This test asserts that Stream.prototype.pipe does not leave listeners -// hanging on the source or dest. -require('../common'); -const stream = require('stream'); -const assert = require('assert'); - -function Writable() { - this.writable = true; - this.endCalls = 0; - stream.Stream.call(this); -} -Object.setPrototypeOf(Writable.prototype, stream.Stream.prototype); -Object.setPrototypeOf(Writable, stream.Stream); -Writable.prototype.end = function() { - this.endCalls++; -}; - -Writable.prototype.destroy = function() { - this.endCalls++; -}; - -function Readable() { - this.readable = true; - stream.Stream.call(this); -} -Object.setPrototypeOf(Readable.prototype, stream.Stream.prototype); -Object.setPrototypeOf(Readable, stream.Stream); - -function Duplex() { - this.readable = true; - Writable.call(this); -} -Object.setPrototypeOf(Duplex.prototype, Writable.prototype); -Object.setPrototypeOf(Duplex, Writable); - -let i = 0; -const limit = 100; - -let w = new Writable(); - -let r; - -for (i = 0; i < limit; i++) { - r = new Readable(); - r.pipe(w); - r.emit('end'); -} -assert.strictEqual(r.listeners('end').length, 0); -assert.strictEqual(w.endCalls, limit); - -w.endCalls = 0; - -for (i = 0; i < limit; i++) { - r = new Readable(); - r.pipe(w); - r.emit('close'); -} -assert.strictEqual(r.listeners('close').length, 0); -assert.strictEqual(w.endCalls, limit); - -w.endCalls = 0; - -r = new Readable(); - -for (i = 0; i < limit; i++) { - w = new Writable(); - r.pipe(w); - w.emit('close'); -} -assert.strictEqual(w.listeners('close').length, 0); - -r = new Readable(); -w = new Writable(); -const d = new Duplex(); -r.pipe(d); // pipeline A -d.pipe(w); // pipeline B -assert.strictEqual(r.listeners('end').length, 2); // A.onend, A.cleanup -assert.strictEqual(r.listeners('close').length, 2); // A.onclose, A.cleanup -assert.strictEqual(d.listeners('end').length, 2); // B.onend, B.cleanup -// A.cleanup, B.onclose, B.cleanup -assert.strictEqual(d.listeners('close').length, 3); -assert.strictEqual(w.listeners('end').length, 0); -assert.strictEqual(w.listeners('close').length, 1); // B.cleanup - -r.emit('end'); -assert.strictEqual(d.endCalls, 1); -assert.strictEqual(w.endCalls, 0); -assert.strictEqual(r.listeners('end').length, 0); -assert.strictEqual(r.listeners('close').length, 0); -assert.strictEqual(d.listeners('end').length, 2); // B.onend, B.cleanup -assert.strictEqual(d.listeners('close').length, 2); // B.onclose, B.cleanup -assert.strictEqual(w.listeners('end').length, 0); -assert.strictEqual(w.listeners('close').length, 1); // B.cleanup - -d.emit('end'); -assert.strictEqual(d.endCalls, 1); -assert.strictEqual(w.endCalls, 1); -assert.strictEqual(r.listeners('end').length, 0); -assert.strictEqual(r.listeners('close').length, 0); -assert.strictEqual(d.listeners('end').length, 0); -assert.strictEqual(d.listeners('close').length, 0); -assert.strictEqual(w.listeners('end').length, 0); -assert.strictEqual(w.listeners('close').length, 0); |