Gecko [ lorencats.com ]

Name	Size	Permission
node_modules	[ DIR ]	drwxr-xr-x
.travis.yml	58 B	-rw-r--r--
README.md	1.39 KB	-rw-r--r--
example.js	313 B	-rw-r--r--
index.js	1.14 KB	-rw-r--r--
package.json	1.66 KB	-rw-r--r--
test.js	2.99 KB	-rw-r--r--

Code Editor : index.js

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

${this.title}

Code Editor : index.js