(fix) TopicMessageQuery#unsubscribe() attempts to re-subscribe

src/topic/SubscriptionHandle.js

@@ -22,6 +22,9 @@ export default class SubscriptionHandle {
     constructor() {
         /** @type {{(): void} | null} */
         this._call = null;
+
+        /** @type {boolean} */
+        this._unsubscribed = false;
     }
 
     /**
@@ -34,6 +37,7 @@ export default class SubscriptionHandle {
 
     unsubscribe() {
         if (this._call != null) {
+            this._unsubscribed = true;
             this._call();
         }
     }

src/topic/TopicMessageQuery.js

@@ -438,6 +438,10 @@
                     const message =
                         error instanceof Error ? error.message : error.details;
 
+                    if (this._handle?._unsubscribed) {
+                        return;
+                    }
+
                     if (
                         this._attempt < this._maxAttempts &&
                         this._retryHandler(error)

test/unit/TopicMessageMocking.js

@@ -58,4 +58,30 @@ describe("TopicMessageMocking", function () {
 
         expect(finished).to.be.true;
     });
+
+    it("should stop processing messages after unsubscription", async function () {
+        ({ client, servers } = await Mocker.withResponses([
+            [{ response: TOPIC_MESSAGE }],
+            [{ response: TOPIC_MESSAGE }],
+        ]));
+
+        let messageProcessed = false;
+
+        handle = new TopicMessageQuery()
+            .setTopicId("0.0.3")
+            .subscribe(client, () => {
+                messageProcessed = true;
+            });
+
+        handle.unsubscribe();
+
+        const startTime = Date.now();
+
+        while (!messageProcessed && Date.now() < startTime + 5000) {
+            await new Promise((resolved) => setTimeout(resolved, 2000));
+        }
+
+        expect(messageProcessed).to.be.false;
+    });
+
 });