From 26ba4911e933c6545902185faeab46ecc8b36a46 Mon Sep 17 00:00:00 2001
From: Matthew Yasul <yasulmatthew@gmail.com>
Date: Sun, 30 Apr 2023 08:46:24 +0800
Subject: [PATCH] Properly close the client before rejecting on error

---
 index.js | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/index.js b/index.js
index c74e0a0..08b3fe9 100644
--- a/index.js
+++ b/index.js
@@ -158,8 +158,11 @@ module.exports = {
         },
         error: (err) => {
           removePromiseResolutionListeners();
-          client.end();
-          reject(err);            // Reject on error
+
+          const clientEndPromise = new Promise(res => client.end(true, {}, () => res(err)));
+
+          // Reject on error after client is properly closed
+          clientEndPromise.then(() => reject(err));
         }
       };