Additional async connection fixes

Author: ChristianJStarr

projectx_sdk/realtime/market_hub.py

@@ -264,7 +264,9 @@ def unsubscribe_quotes(self, contract_id: str, callback: Optional[Callable] = No
                 and contract_id in self._subscribed_quotes
                 and self._connection
             ):
-                self._connection.invoke("UnsubscribeContractQuotes", contract_id)
+                asyncio.create_task(
+                    self._connection.invoke("UnsubscribeContractQuotes", contract_id)
+                )
                 self._subscribed_quotes.remove(contract_id)
 
     def subscribe_trades(
@@ -281,7 +283,7 @@ def subscribe_trades(
             self._trade_callbacks[contract_id] = []
 
             if self._connection:
-                self._connection.invoke("SubscribeContractTrades", contract_id)
+                asyncio.create_task(self._connection.invoke("SubscribeContractTrades", contract_id))
                 self._subscribed_trades.add(contract_id)
 
         self._trade_callbacks[contract_id].append(callback)
@@ -307,7 +309,9 @@ def unsubscribe_trades(self, contract_id: str, callback: Optional[Callable] = No
                 and contract_id in self._subscribed_trades
                 and self._connection
             ):
-                self._connection.invoke("UnsubscribeContractTrades", contract_id)
+                asyncio.create_task(
+                    self._connection.invoke("UnsubscribeContractTrades", contract_id)
+                )
                 self._subscribed_trades.remove(contract_id)
 
     def subscribe_market_depth(
@@ -324,7 +328,9 @@ def subscribe_market_depth(
             self._depth_callbacks[contract_id] = []
 
             if self._connection:
-                self._connection.invoke("SubscribeContractMarketDepth", contract_id)
+                asyncio.create_task(
+                    self._connection.invoke("SubscribeContractMarketDepth", contract_id)
+                )
                 self._subscribed_depth.add(contract_id)
 
         self._depth_callbacks[contract_id].append(callback)
@@ -352,7 +358,9 @@ def unsubscribe_market_depth(
                 and contract_id in self._subscribed_depth
                 and self._connection
             ):
-                self._connection.invoke("UnsubscribeContractMarketDepth", contract_id)
+                asyncio.create_task(
+                    self._connection.invoke("UnsubscribeContractMarketDepth", contract_id)
+                )
                 self._subscribed_depth.remove(contract_id)
 
     def reconnect_subscriptions(self) -> None:
@@ -362,15 +370,17 @@ def reconnect_subscriptions(self) -> None:
 
         # Resubscribe to quotes
         for contract_id in self._subscribed_quotes:
-            self._connection.invoke("SubscribeContractQuotes", contract_id)
+            asyncio.create_task(self._connection.invoke("SubscribeContractQuotes", contract_id))
 
         # Resubscribe to trades
         for contract_id in self._subscribed_trades:
-            self._connection.invoke("SubscribeContractTrades", contract_id)
+            asyncio.create_task(self._connection.invoke("SubscribeContractTrades", contract_id))
 
         # Resubscribe to market depth
         for contract_id in self._subscribed_depth:
-            self._connection.invoke("SubscribeContractMarketDepth", contract_id)
+            asyncio.create_task(
+                self._connection.invoke("SubscribeContractMarketDepth", contract_id)
+            )
 
     def _on_connected(self) -> None:
         """

projectx_sdk/realtime/user_hub.py

@@ -365,7 +365,7 @@ def unsubscribe_trades(self, account_id):
 
         return self
 
-    def invoke(self, method, *args):
+    async def invoke(self, method, *args):
         """
         Invoke a hub method.
 
@@ -379,7 +379,7 @@ def invoke(self, method, *args):
         if not self._is_connected or not self._connection:
             raise Exception("Not connected to hub")
 
-        return self._connection.invoke(method, *args)
+        return await self._connection.invoke(method, *args)
 
     def _handle_account_update(self, data):
         """

setup.py

@@ -37,7 +37,7 @@
 
 setup(
     name="projectx-sdk",
-    version="0.2.4",
+    version="0.2.5",
     author="Christian Starr",
     author_email="christianjstarr@icloud.com",
     description="UnofficialPython SDK for the ProjectX Gateway API",