fix 'end' call for helenus object stream

godaddy · Dec 19, 2014 · 093611b · 093611b
1 parent dc012e0
commit 093611b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/drivers/helenus.js b/lib/drivers/helenus.js
@@ -134,7 +134,7 @@ HelenusDriver.prototype.streamCqlOnDriver = function streamCqlOnDriver(pool, cql
         if (err) {
           transformStream.emit('error', err);
         }
-        transformStream.emit('end');
+        transformStream.end();
       });
     });
   });