a

lib/index.js

@@ -398,9 +398,14 @@ class BankClient {
                 }
                 finally {
                     console.log('reconnecting in 5s');
-                    setTimeout(() => {
-                        this.connectWebsocket(peerAddr, topic, connectCallback, messageCallback);
-                    }, 5000);
+                    setTimeout(() => __awaiter(this, void 0, void 0, function* () {
+                        try {
+                            yield this.connectWebsocket(peerAddr, topic, connectCallback, messageCallback);
+                        }
+                        catch (e) {
+                            console.error('error reconnecting', e);
+                        }
+                    }), 5000);
                 }
             };
             ws.on('error', err => {

src/index.ts

@@ -397,8 +397,12 @@ export class BankClient {
           ws.terminate();
         } finally {
           console.log('reconnecting in 5s');
-          setTimeout(() => {
-            this.connectWebsocket(peerAddr, topic, connectCallback, messageCallback);
+          setTimeout(async () => {
+            try {
+              await this.connectWebsocket(peerAddr, topic, connectCallback, messageCallback);
+            } catch (e) {
+              console.error('error reconnecting', e);
+            }
           }, 5000);
         }
       };