Handle errors from fsWriteStreamAtomic

sindresorhus · Mar 26, 2015 · 71e5979 · 71e5979
1 parent 7aea27e
commit 71e5979
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/util.js b/lib/util.js
@@ -109,7 +109,6 @@ exports.save = function (streams, cb) {
 
  var dest = path.join(this.dest(), stream.filename);
  var write = fsWriteStreamAtomic(dest);
- var pipe = stream.pipe(write);
 
  files.push(write.__atomicTmp);
 
@@ -118,10 +117,12 @@ exports.save = function (streams, cb) {
  end(next.bind(null, err));
  });
 
- pipe.on('finish', next);
- pipe.on('error', function (err) {
+ write.on('finish', next);
+ write.on('error', function (err) {
  end(next.bind(null, err));
  });
+
+ stream.pipe(write);
  }.bind(this));
  }.bind(this), function (err) {
  if (err) {