This commit includes:

-when using mongodb driver with streaming response the proccess doesn't finish.
iantocristian · Dec 21, 2016 · b6a470d · b6a470d
1 parent 1d4bdab
commit b6a470d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/index.js b/index.js
@@ -46,7 +46,9 @@ function CSVTransform(dbStream, options) {
   }
 
   self._dbStream = dbStream;
-
+  self._dbStream.on('end', function() {
+          self.push(null);
+  });
   self._dbStream.on('close', function() {
     self.push(null);
   });
@@ -277,4 +279,3 @@ function defaultFormat(formatArgs) {
 
   formatArgs.formattedValue = formattedValue;
 }
-