Merge pull request #859 from Congelli501/patch-1

Fix issue #711: close emitted before end
sidorares · Oct 14, 2018 · 24c251c · 24c251c
2 parents 6953856 + ad92d20
commit 24c251c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/commands/query.js b/lib/commands/query.js
@@ -245,8 +245,8 @@ class Query extends Command {
       stream.emit('error', err); // Pass on any errors
     });
     this.on('end', function () {
-      stream.emit('close'); // notify readers that query has completed
       stream.push(null); // pushing null, indicating EOF
+      stream.emit('close'); // notify readers that query has completed
     });
     this.on('fields', function (fields) {
       stream.emit('fields', fields); // replicate old emitter