build: release v2.4.0

Author: pozil

dist/client.cjs

@@ -521,7 +521,9 @@ var PubSubApiClient = class {
         eventEmitter.emit("error", error);
       });
       subscription.on("status", (status) => {
-        this.#logger.info(`gRPC stream status: ${status}`);
+        this.#logger.info(
+          `gRPC stream status: ${JSON.stringify(status)}`
+        );
         eventEmitter.emit("status", status);
       });
       return eventEmitter;
@@ -569,6 +571,10 @@ var PubSubApiClient = class {
       });
     }
   }
+  close() {
+    this.#logger.info("closing gRPC stream");
+    this.#client.close();
+  }
   async #getEventSchema(topicName) {
     let schema = this.#schemaChache.get(topicName);
     if (!schema) {

dist/client.d.ts

@@ -68,6 +68,10 @@ export default class PubSubApiClient {
      * @returns {Promise<PublishResult>} Promise holding a PublishResult object with replayId and correlationKey
      */
     publish(topicName: string, payload: any, correlationKey?: string): Promise<PublishResult>;
+    /**
+     * Closes the gRPC connection. The client will no longer receive events for any topic.
+     */
+    close(): void;
     #private;
 }
 export type Schema = {

dist/client.d.ts.map

@@ -493,7 +493,9 @@ var PubSubApiClient = class {
         eventEmitter.emit("error", error);
       });
       subscription.on("status", (status) => {
-        this.#logger.info(`gRPC stream status: ${status}`);
+        this.#logger.info(
+          `gRPC stream status: ${JSON.stringify(status)}`
+        );
         eventEmitter.emit("status", status);
       });
       return eventEmitter;
@@ -541,6 +543,10 @@ var PubSubApiClient = class {
       });
     }
   }
+  close() {
+    this.#logger.info("closing gRPC stream");
+    this.#client.close();
+  }
   async #getEventSchema(topicName) {
     let schema = this.#schemaChache.get(topicName);
     if (!schema) {