From f8c369bef120e83b13959996e162d24f8ce6d494 Mon Sep 17 00:00:00 2001
From: Kiko Beats <josefrancisco.verdu@gmail.com>
Date: Sat, 6 Nov 2021 00:06:48 +0100
Subject: [PATCH] [Refactoring] GramJs: Replace deprecated functions (#32)

---
 src/lib/gramjs/extensions/PromisedWebSockets.js | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/lib/gramjs/extensions/PromisedWebSockets.js b/src/lib/gramjs/extensions/PromisedWebSockets.js
index 8c6a65736..1828fb87e 100644
--- a/src/lib/gramjs/extensions/PromisedWebSockets.js
+++ b/src/lib/gramjs/extensions/PromisedWebSockets.js
@@ -128,16 +128,13 @@ class PromisedWebSockets {
 
     receive() {
         this.client.onmessage = async (message) => {
-            const release = await mutex.acquire();
-            try {
+            await mutex.runExclusive(async () => {
                 const data = message.data instanceof ArrayBuffer
                     ? Buffer.from(message.data)
                     : Buffer.from(await new Response(message.data).arrayBuffer());
                 this.stream = Buffer.concat([this.stream, data]);
                 this.resolveRead(true);
-            } finally {
-                release();
-            }
+            });
         };
     }
 }