deno.land / std@0.166.0 / node / _tools / test / parallel / test-stream-pipe-same-destination-twice.js
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 18.12.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
'use strict';const common = require('../common');
// Regression test for https://github.com/nodejs/node/issues/12718.// Tests that piping a source stream twice to the same destination stream// works, and that a subsequent unpipe() call only removes the pipe *once*.const assert = require('assert');const { PassThrough, Writable } = require('stream');
{ const passThrough = new PassThrough(); const dest = new Writable({ write: common.mustCall((chunk, encoding, cb) => { assert.strictEqual(`${chunk}`, 'foobar'); cb(); }) });
passThrough.pipe(dest); passThrough.pipe(dest);
assert.strictEqual(passThrough._events.data.length, 2); assert.strictEqual(passThrough._readableState.pipes.length, 2); assert.strictEqual(passThrough._readableState.pipes[0], dest); assert.strictEqual(passThrough._readableState.pipes[1], dest);
passThrough.unpipe(dest);
assert.strictEqual(passThrough._events.data.length, 1); assert.strictEqual(passThrough._readableState.pipes.length, 1); assert.deepStrictEqual(passThrough._readableState.pipes, [dest]);
passThrough.write('foobar'); passThrough.pipe(dest);}
{ const passThrough = new PassThrough(); const dest = new Writable({ write: common.mustCall((chunk, encoding, cb) => { assert.strictEqual(`${chunk}`, 'foobar'); cb(); }, 2) });
passThrough.pipe(dest); passThrough.pipe(dest);
assert.strictEqual(passThrough._events.data.length, 2); assert.strictEqual(passThrough._readableState.pipes.length, 2); assert.strictEqual(passThrough._readableState.pipes[0], dest); assert.strictEqual(passThrough._readableState.pipes[1], dest);
passThrough.write('foobar');}
{ const passThrough = new PassThrough(); const dest = new Writable({ write: common.mustNotCall() });
passThrough.pipe(dest); passThrough.pipe(dest);
assert.strictEqual(passThrough._events.data.length, 2); assert.strictEqual(passThrough._readableState.pipes.length, 2); assert.strictEqual(passThrough._readableState.pipes[0], dest); assert.strictEqual(passThrough._readableState.pipes[1], dest);
passThrough.unpipe(dest); passThrough.unpipe(dest);
assert.strictEqual(passThrough._events.data, undefined); assert.strictEqual(passThrough._readableState.pipes.length, 0);
passThrough.write('foobar');}
Version Info