From 8e3819dbe11ea5ec05a8bcfc666d7a75333d5d5d Mon Sep 17 00:00:00 2001 From: Lawrence Forooghian Date: Mon, 29 May 2023 10:25:18 -0300 Subject: [PATCH] Make Message.fromResponseBody async Preparation for #1293 (making ICipher.decrypt asynchronous). --- src/common/lib/client/channel.ts | 2 +- src/common/lib/types/message.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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, unpacked?: boolean ) { - return Message.fromResponseBody(body, options, unpacked ? undefined : format); + return await Message.fromResponseBody(body, options, unpacked ? undefined : format); }).get(params as Record, 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, options: ChannelOptions | EncodingDecodingContext, format?: Utils.Format - ): Message[] { + ): Promise { if (format) { body = Utils.decodeBody(body, format); }