diff --git a/lib/client/network/protocol37/operations/query.js b/lib/client/network/protocol37/operations/query.js
index 15d414a..6c8848e 100644
--- a/lib/client/network/protocol37/operations/query.js
+++ b/lib/client/network/protocol37/operations/query.js
@@ -88,7 +88,7 @@ module.exports = Operation.extend({
             this.readRecord(
               data.count,
               record => {
-                if(!this.data.stream.closed){
+                if(!this.data.stream.queryClosed){
                   this.data.stream.push(record);
                 }
               },
@@ -132,7 +132,7 @@ module.exports = Operation.extend({
         this.data.stream.requestedNext = true;
         this.data.stream._fetchNext();
       } else {
-        this.data.stream.closed = true;
+        this.data.stream.queryClosed = true;
         this.data.stream.push(null);
       }
     });