diff --git a/index.js b/index.js index b6fcf85..b256753 100644 --- a/index.js +++ b/index.js @@ -5,6 +5,7 @@ var Combine = require('ordered-read-streams'); var unique = require('unique-stream'); var glob = require('glob'); +var pumpify = require('pumpify'); var resolveGlob = require('to-absolute-glob'); var isNegatedGlob = require('is-negated-glob'); var globParent = require('glob-parent'); @@ -124,13 +125,8 @@ var gs = { // Then just pipe them to a single unique stream and return it var aggregate = new Combine(streams); var uniqueStream = unique('path'); - var returnStream = aggregate.pipe(uniqueStream); - aggregate.on('error', function(err) { - returnStream.emit('error', err); - }); - - return returnStream; + return pumpify.obj(aggregate, uniqueStream); function streamFromPositive(positive) { var negativeGlobs = negatives.filter(indexGreaterThan(positive.index)) diff --git a/package.json b/package.json index c2b010e..4655358 100644 --- a/package.json +++ b/package.json @@ -26,6 +26,7 @@ "glob-parent": "^3.0.0", "is-negated-glob": "^1.0.0", "ordered-read-streams": "^0.3.0", + "pumpify": "^1.3.5", "through2": "^0.6.0", "to-absolute-glob": "^0.1.1", "unique-stream": "^2.0.2"