From 70a60920794a246098145027c52a1ef79de67d46 Mon Sep 17 00:00:00 2001
From: Derrick Hammer <derrick@derrickhammer.com>
Date: Tue, 30 Aug 2022 22:43:05 -0400
Subject: [PATCH] *Update dist

---
 dist/query/streaming.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dist/query/streaming.js b/dist/query/streaming.js
index aa06668..4812b9f 100644
--- a/dist/query/streaming.js
+++ b/dist/query/streaming.js
@@ -35,7 +35,6 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
                 if (timer && timer.close) {
                     clearTimeout(timer);
                 }
-                socket.end();
                 const response = unpack(res);
                 if (response && response.error) {
                     this._errors[relay] = response.error;
@@ -44,6 +43,7 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
                 if (response?.data.done) {
                     this._responses[relay] = {};
                     resolve(null);
+                    socket.end();
                     return;
                 }
                 this._options.streamHandler(response?.data.data);