diff --git a/dist/query/streaming.d.ts.map b/dist/query/streaming.d.ts.map
index 9af56ca..f7d6d00 100644
--- a/dist/query/streaming.d.ts.map
+++ b/dist/query/streaming.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"streaming.d.ts","sourceRoot":"","sources":["../../src/query/streaming.ts"],"names":[],"mappings":";AAAA,OAAO,cAAc,MAAM,aAAa,CAAC;AACzC,OAAO,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AAIhC,OAAO,KAAK,EAAE,UAAU,EAAe,MAAM,sBAAsB,CAAC;AACpE,OAAO,UAAU,MAAM,eAAe,CAAC;AACvC,OAAO,EAAE,wBAAwB,EAAE,MAAM,aAAa,CAAC;AAEvD,MAAM,CAAC,OAAO,OAAO,iBAAkB,SAAQ,cAAc;IAC3D,SAAS,CAAC,QAAQ,EAAE,wBAAwB,CAAC;IAC7C,SAAS,CAAC,SAAS,UAAS;gBAE1B,OAAO,EAAE,UAAU,EACnB,KAAK,EAAE,MAAM,GAAG,MAAM,EACtB,KAAK,EAAE,UAAU,EACjB,OAAO,EAAE,wBAAwB;IAM5B,MAAM;cAIG,UAAU,CAAC,KAAK,EAAE,MAAM,GAAG,MAAM,GAAG,OAAO,CAAC,GAAG,CAAC;CAqEjE"}
\ No newline at end of file
+{"version":3,"file":"streaming.d.ts","sourceRoot":"","sources":["../../src/query/streaming.ts"],"names":[],"mappings":";AAAA,OAAO,cAAc,MAAM,aAAa,CAAC;AACzC,OAAO,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AAIhC,OAAO,KAAK,EAAE,UAAU,EAAe,MAAM,sBAAsB,CAAC;AACpE,OAAO,UAAU,MAAM,eAAe,CAAC;AACvC,OAAO,EAAE,wBAAwB,EAAE,MAAM,aAAa,CAAC;AAEvD,MAAM,CAAC,OAAO,OAAO,iBAAkB,SAAQ,cAAc;IAC3D,SAAS,CAAC,QAAQ,EAAE,wBAAwB,CAAC;IAC7C,SAAS,CAAC,SAAS,UAAS;gBAE1B,OAAO,EAAE,UAAU,EACnB,KAAK,EAAE,MAAM,GAAG,MAAM,EACtB,KAAK,EAAE,UAAU,EACjB,OAAO,EAAE,wBAAwB;IAM5B,MAAM;cAIG,UAAU,CAAC,KAAK,EAAE,MAAM,GAAG,MAAM,GAAG,OAAO,CAAC,GAAG,CAAC;CAwEjE"}
\ No newline at end of file
diff --git a/dist/query/streaming.js b/dist/query/streaming.js
index 1e568f8..918805d 100644
--- a/dist/query/streaming.js
+++ b/dist/query/streaming.js
@@ -40,13 +40,14 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
                 resolve(null);
                 socket.end();
             };
-            socket.on("data", (res) => {
+            const listener = (res) => {
                 relay = relay;
                 if (timer && timer.close) {
                     clearTimeout(timer);
                 }
                 if (this._canceled) {
                     socket.write(pack({ cancel: true }));
+                    socket.off("data", listener);
                     finish();
                     return;
                 }
@@ -60,7 +61,8 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
                     return;
                 }
                 this._options.streamHandler(response?.data.data);
-            });
+            };
+            socket.on("data", listener);
             socket.on("error", (error) => {
                 relay = relay;
                 this._errors[relay] = error;