diff options
Diffstat (limited to 'deps/node/deps/npm/node_modules/sorted-union-stream/index.js')
-rw-r--r-- | deps/node/deps/npm/node_modules/sorted-union-stream/index.js | 59 |
1 files changed, 0 insertions, 59 deletions
diff --git a/deps/node/deps/npm/node_modules/sorted-union-stream/index.js b/deps/node/deps/npm/node_modules/sorted-union-stream/index.js deleted file mode 100644 index 8c73c57d..00000000 --- a/deps/node/deps/npm/node_modules/sorted-union-stream/index.js +++ /dev/null @@ -1,59 +0,0 @@ -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 |