dont emit closing events

index.js

@@ -17,7 +17,15 @@ module.exports = function (stream, opts) {
   var eventNamesToEmit = toMap(opts.events || []);
   var catchAll = Object.keys(eventNamesToEmit).length === 0;
 
-  var eventNamesToExclude = toMap(opts.excludeEvents || []);
+  var endEvents = [
+    'abort',
+    'close',
+    'destroy',
+    'end',
+    'finish',
+    'prefinish'
+  ];
+  var eventNamesToExclude = toMap(opts.excludeEvents || endEvents);
 
   watchPipe(stream);
 

test.js

@@ -14,6 +14,23 @@ describe('stream-forward', function () {
     assert.strictEqual(sourceStream, returnedStream);
   });
 
+  it('does not try to finish a piped stream', function () {
+    var streamThatErrors = through();
+
+    streamForward(streamThatErrors)
+      .pipe(through(function(chunk, enc, next) {
+        // let this back up so that if the source stream emits 'finish', and
+        // streamforward tries to re-emit that event on this stream, it will
+        // throw.
+      }));
+
+    streamThatErrors.write('blah');
+
+    assert.doesNotThrow(function() {
+      streamThatErrors.emit('prefinish');
+    });
+  });
+
   it('forwards all events by default', function (done) {
     var eventsEmitted = 0;