diff --git a/src/common/lib/client/channel.ts b/src/common/lib/client/channel.ts
index a5e156dc24..8937709d5e 100644
--- a/src/common/lib/client/channel.ts
+++ b/src/common/lib/client/channel.ts
@@ -102,7 +102,7 @@ class Channel extends EventEmitter {
       headers: Record<string, string>,
       unpacked?: boolean
     ) {
-      return Message.fromResponseBody(body, options, unpacked ? undefined : format);
+      return await Message.fromResponseBody(body, options, unpacked ? undefined : format);
     }).get(params as Record<string, unknown>, callback);
   }
 
diff --git a/src/common/lib/types/message.ts b/src/common/lib/types/message.ts
index 5f3232bbf8..540ae67de5 100644
--- a/src/common/lib/types/message.ts
+++ b/src/common/lib/types/message.ts
@@ -301,11 +301,11 @@ class Message {
     context.baseEncodedPreviousPayload = lastPayload;
   }
 
-  static fromResponseBody(
+  static async fromResponseBody(
     body: Array<Message>,
     options: ChannelOptions | EncodingDecodingContext,
     format?: Utils.Format
-  ): Message[] {
+  ): Promise<Message[]> {
     if (format) {
       body = Utils.decodeBody(body, format);
     }