Make Message.fromResponseBody async

Preparation for #1293 (making ICipher.decrypt asynchronous).
ably · Jun 1, 2023 · ce1d837 · ce1d837
1 parent 096a948
commit ce1d837
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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);
     }