Merge pull request #48 from pozil/pozil/fix-request-additional-events

fix: request additional events
pozil · Nov 15, 2024 · d1af726 · d1af726
2 parents 4bb6b36 + 53ffc18
commit d1af726
Show file tree

Hide file tree

Showing 10 changed files with 983 additions and 394 deletions.
diff --git a/dist/client.cjs b/dist/client.cjs
@@ -815,6 +815,9 @@ var PubSubApiClient = class {
               this.#logger.error(parseError);
             }
             if (subscription.info.receivedEventCount === subscription.info.requestedEventCount) {
+              this.#logger.debug(
+                `${topicName} - Reached last of ${subscription.info.requestedEventCount} requested event on channel.`
+              );
               if (isInfiniteEventRequest) {
                 this.requestAdditionalEvents(
                   subscription.info.topicName,
@@ -889,7 +892,7 @@ var PubSubApiClient = class {
     }
     subscription.receivedEventCount = 0;
     subscription.requestedEventCount = numRequested;
-    subscription.write({
+    subscription.grpcSubscription.write({
       topicName,
       numRequested
     });

diff --git a/dist/client.d.ts.map b/dist/client.d.ts.map
diff --git a/dist/client.js b/dist/client.js
@@ -782,6 +782,9 @@ var PubSubApiClient = class {
               this.#logger.error(parseError);
             }
             if (subscription.info.receivedEventCount === subscription.info.requestedEventCount) {
+              this.#logger.debug(
+                `${topicName} - Reached last of ${subscription.info.requestedEventCount} requested event on channel.`
+              );
               if (isInfiniteEventRequest) {
                 this.requestAdditionalEvents(
                   subscription.info.topicName,
@@ -856,7 +859,7 @@ var PubSubApiClient = class {
     }
     subscription.receivedEventCount = 0;
     subscription.requestedEventCount = numRequested;
-    subscription.write({
+    subscription.grpcSubscription.write({
       topicName,
       numRequested
     });