Async fixes to invoke methods

Author: ChristianJStarr

projectx_sdk/realtime/market_hub.py

@@ -1,5 +1,6 @@
 """Market hub implementation for the ProjectX Gateway API real-time data."""
 
+import asyncio
 import logging
 from typing import Any, Callable, Dict, Optional
 
@@ -237,7 +238,7 @@ def subscribe_quotes(
             self._quote_callbacks[contract_id] = []
 
             if self._connection:
-                self._connection.invoke("SubscribeContractQuotes", contract_id)
+                asyncio.create_task(self._connection.invoke("SubscribeContractQuotes", contract_id))
                 self._subscribed_quotes.add(contract_id)
 
         self._quote_callbacks[contract_id].append(callback)

projectx_sdk/realtime/user_hub.py

@@ -1,5 +1,6 @@
 """User hub implementation for the ProjectX Gateway API."""
 
+import asyncio
 import logging
 from typing import Callable, Dict, List, Optional, Set
 
@@ -229,7 +230,7 @@ def subscribe_accounts(self, callback=None):
             self._account_callbacks.append(callback)
 
         if self._is_connected:
-            self.invoke("SubscribeAccounts")
+            asyncio.create_task(self.invoke("SubscribeAccounts"))
             self._account_subscribed = True
 
         return self
@@ -242,7 +243,7 @@ def unsubscribe_accounts(self):
             self: For method chaining
         """
         if self._is_connected and self._account_subscribed:
-            self.invoke("UnsubscribeAccounts")
+            asyncio.create_task(self.invoke("UnsubscribeAccounts"))
             self._account_subscribed = False
 
         return self
@@ -265,7 +266,7 @@ def subscribe_orders(self, account_id, callback=None):
             self._order_callbacks[account_id].append(callback)
 
         if self._is_connected:
-            self.invoke("SubscribeOrders", account_id)
+            asyncio.create_task(self.invoke("SubscribeOrders", account_id))
             self._subscribed_orders.add(account_id)
 
         return self
@@ -281,7 +282,7 @@ def unsubscribe_orders(self, account_id):
             self: For method chaining
         """
         if self._is_connected and account_id in self._subscribed_orders:
-            self.invoke("UnsubscribeOrders", account_id)
+            asyncio.create_task(self.invoke("UnsubscribeOrders", account_id))
             self._subscribed_orders.discard(account_id)
 
         return self
@@ -304,7 +305,7 @@ def subscribe_positions(self, account_id, callback=None):
             self._position_callbacks[account_id].append(callback)
 
         if self._is_connected:
-            self.invoke("SubscribePositions", account_id)
+            asyncio.create_task(self.invoke("SubscribePositions", account_id))
             self._subscribed_positions.add(account_id)
 
         return self
@@ -320,7 +321,7 @@ def unsubscribe_positions(self, account_id):
             self: For method chaining
         """
         if self._is_connected and account_id in self._subscribed_positions:
-            self.invoke("UnsubscribePositions", account_id)
+            asyncio.create_task(self.invoke("UnsubscribePositions", account_id))
             self._subscribed_positions.discard(account_id)
 
         return self
@@ -343,7 +344,7 @@ def subscribe_trades(self, account_id, callback=None):
             self._trade_callbacks[account_id].append(callback)
 
         if self._is_connected:
-            self.invoke("SubscribeTrades", account_id)
+            asyncio.create_task(self.invoke("SubscribeTrades", account_id))
             self._subscribed_trades.add(account_id)
 
         return self
@@ -359,7 +360,7 @@ def unsubscribe_trades(self, account_id):
             self: For method chaining
         """
         if self._is_connected and account_id in self._subscribed_trades:
-            self.invoke("UnsubscribeTrades", account_id)
+            asyncio.create_task(self.invoke("UnsubscribeTrades", account_id))
             self._subscribed_trades.discard(account_id)
 
         return self

setup.py

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