if a stream receives the unpipe event, end it

Author: Tom Macie

index.js

@@ -29,6 +29,7 @@ function promiseFromStreams(streams) {
 
     streams.forEach((stream, i) => {
 
+      stream.on('unpipe', () => stream.end())
       stream.on('error', error => {
 
         stream.end()