#$@%#$%!

Ngiler SH3LL 360
: / lib / node_modules / npm / node_modules / sorted-union-stream /

Information Server
MySQL : OFF Perl : OFF CURL : ON WGET : OFF PKEXEC : OFF

Directive	Local Value
IP Address	162.0.209.101
System	Linux premium169.web-hosting.com 4.18.0-553.50.1.lve.el8.x86_64 #1 SMP Thu Apr 17 19:10:24 UTC 2025 x86_64
User	luxeelil
PHP Version	8.0.30
Software	LiteSpeed
Doc root	Writable

Edit File : index.js \| Size : 1.14 KB
var iterate = require('stream-iterate') var from = require('from2') var defaultKey = function (val) { return val.key \|\| val } var union = function (streamA, streamB, toKey) { var readA = iterate(streamA) var readB = iterate(streamB) if (!toKey) toKey = defaultKey var stream = from.obj(function loop (size, cb) { readA(function (err, dataA, nextA) { if (err) return cb(err) readB(function (err, dataB, nextB) { if (err) return cb(err) if (!dataA && !dataB) return cb(null, null) if (!dataA) { nextB() return cb(null, dataB) } if (!dataB) { nextA() return cb(null, dataA) } var keyA = toKey(dataA) var keyB = toKey(dataB) if (keyA === keyB) { nextB() return loop(size, cb) } if (keyA < keyB) { nextA() return cb(null, dataA) } nextB() cb(null, dataB) }) }) }) stream.on('close', function () { if (streamA.destroy) streamA.destroy() if (streamB.destroy) streamB.destroy() }) return stream } module.exports = union Back

Edit File : index.js | Size : 1.14 KB

var iterate = require('stream-iterate')
var from = require('from2')

var defaultKey = function (val) {
  return val.key || val
}

var union = function (streamA, streamB, toKey) {
  var readA = iterate(streamA)
  var readB = iterate(streamB)

if (!toKey) toKey = defaultKey

var stream = from.obj(function loop (size, cb) {
    readA(function (err, dataA, nextA) {
      if (err) return cb(err)
      readB(function (err, dataB, nextB) {
        if (err) return cb(err)

if (!dataA && !dataB) return cb(null, null)

if (!dataA) {
          nextB()
          return cb(null, dataB)
        }

if (!dataB) {
          nextA()
          return cb(null, dataA)
        }

var keyA = toKey(dataA)
        var keyB = toKey(dataB)

if (keyA === keyB) {
          nextB()
          return loop(size, cb)
        }

if (keyA < keyB) {
          nextA()
          return cb(null, dataA)
        }

nextB()
        cb(null, dataB)
      })
    })
  })

stream.on('close', function () {
    if (streamA.destroy) streamA.destroy()
    if (streamB.destroy) streamB.destroy()
  })

return stream
}

module.exports = union

Back