Software: Apache. PHP/8.3.27 

uname -a: Linux pdx1-shared-a4-04 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64 

uid=6659440(dh_z2jmpm) gid=2086089(pg10499364) groups=2086089(pg10499364)  

Safe-mode: OFF (not secure)

/usr/share/nodejs/fast-glob/out/utils/   drwxr-xr-x
Free 682.71 GB of 879.6 GB (77.62%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     stream.spec.js (1.87 KB)      -rw-r--r--

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const assert = require("assert");
const stream = require("stream");
const util = require("./stream");
describe('Utils → Stream', () => {
    describe('.merge', () => {
        it('should merge two streams into one stream', () => {
            const first = new stream.PassThrough();
            const second = new stream.PassThrough();
            const expected = 3;
            const mergedStream = util.merge([first, second]);
            const actual = mergedStream.listenerCount('close');
            assert.strictEqual(actual, expected);
        });
        it('should propagate errors into merged stream', (done) => {
            const first = new stream.PassThrough();
            const second = new stream.PassThrough();
            const expected = [1, 2, 3];
            const mergedStream = util.merge([first, second]);
            const actual = [];
            mergedStream.on('error', (error) => actual.push(error));
            mergedStream.once('finish', () => {
                assert.deepStrictEqual(actual, expected);
                done();
            });
            first.emit('error', 1);
            second.emit('error', 2);
            mergedStream.emit('error', 3);
        });
        it('should propagate close event to source streams', (done) => {
            const first = new stream.PassThrough();
            const second = new stream.PassThrough();
            const mergedStream = util.merge([first, second]);
            const expected = [1, 2];
            const actual = [];
            first.once('close', () => actual.push(1));
            second.once('close', () => actual.push(2));
            mergedStream.once('finish', () => {
                assert.deepStrictEqual(actual, expected);
                done();
            });
            mergedStream.emit('close');
        });
    });
});