From d483f7e904fa5921dd9a9948b1fb3f483c0a8ce9 Mon Sep 17 00:00:00 2001
From: Justin Starry <justin@solana.com>
Date: Tue, 11 Feb 2020 22:33:50 +0800
Subject: [PATCH] fix: race condition in rpc unsubscribe

---
 web3.js/src/connection.js | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/web3.js/src/connection.js b/web3.js/src/connection.js
index 274a7aa459..d17e0bf49d 100644
--- a/web3.js/src/connection.js
+++ b/web3.js/src/connection.js
@@ -1367,7 +1367,7 @@ export class Connection {
   /**
    * @private
    */
-  async _updateSubscriptions() {
+  _updateSubscriptions() {
     const accountKeys = Object.keys(this._accountChangeSubscriptions).map(
       Number,
     );
@@ -1404,23 +1404,23 @@ export class Connection {
     }
 
     for (let id of accountKeys) {
-      const sub: AccountSubscriptionInfo = this._accountChangeSubscriptions[id];
-      await this._subscribe(sub, 'accountSubscribe', [sub.publicKey]);
+      const sub = this._accountChangeSubscriptions[id];
+      this._subscribe(sub, 'accountSubscribe', [sub.publicKey]);
     }
 
     for (let id of programKeys) {
       const sub = this._programAccountChangeSubscriptions[id];
-      await this._subscribe(sub, 'programSubscribe', [sub.programId]);
+      this._subscribe(sub, 'programSubscribe', [sub.programId]);
     }
 
     for (let id of slotKeys) {
       const sub = this._slotSubscriptions[id];
-      await this._subscribe(sub, 'slotSubscribe', []);
+      this._subscribe(sub, 'slotSubscribe', []);
     }
 
     for (let id of signatureKeys) {
       const sub = this._signatureSubscriptions[id];
-      await this._subscribe(sub, 'signatureSubscribe', [sub.signature]);
+      this._subscribe(sub, 'signatureSubscribe', [sub.signature]);
     }
   }