Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/node-red/node_modules/stream-connect/lib/   drwxr-xr-x
Free 13.1 GB of 57.97 GB (22.59%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     stream-connect.js (1.43 KB)      -rw-r--r--

'use strict'
var Duplex = require('stream').Duplex
var arrayify = require('array-back')
var assert = require('assert')

/**
 * @module stream-connect
 * @example
 * const connect = require('stream-connect')
 */
module.exports = connect

/**
 * Connect streams.
 *
 * @param streams {...external:Duplex} - One or more streams to connect.
 * @return {external:Duplex}
 * @alias module:stream-connect
 */
function connect () {
  var streams = arrayify(arguments)
  assert.ok(streams.length >= 2, 'Must supply at least two input stream.')

  var first = streams[0]
  var last = streams[streams.length - 1]
  var connected = new Duplex({ objectMode: true })

  streams.forEach(function (stream) {
    stream.on('error', function (err) {
      connected.emit('error', err)
    })
  })

  streams.reduce(function (prev, curr) {
    prev.pipe(curr)
    return curr
  })

  connected._write = function (chunk, enc, done) {
    first.write(chunk)
    done()
  }
  connected._read = function () {}
  connected
    .on('finish', function () {
      first.end()
    })
    .on('pipe', function (src) {
      first.emit('pipe', src)
    })

  /* use flowing rather than paused mode, for node 0.10 compatibility. */
  last
    .on('data', function (chunk) {
      connected.push(chunk)
    })
    .on('end', function () {
      connected.push(null)
    })

  return connected
}

/**
 * @external Duplex
 * @see https://nodejs.org/api/stream.html#stream_class_stream_duplex
 */