From 755b7b48dc6e04de661f1672fc0769d2408963e3 Mon Sep 17 00:00:00 2001 From: Blaine Bublitz Date: Mon, 12 Sep 2016 16:05:40 -0700 Subject: [PATCH] Update: Use pumpify to propagate errors/destroy --- index.js | 8 ++------ package.json | 1 + 2 files changed, 3 insertions(+), 6 deletions(-) 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"