Fix missing _use_batching attribute in ProjectXRealtimeClient

- Added super().__init__() call to properly initialize all mixins
- This ensures EventHandlingMixin and ConnectionManagementMixin are properly initialized
- Fixes WebSocket error: 'ProjectXRealtimeClient' object has no attribute '_use_batching'
- Added checks to prevent duplicate initialization of shared attributes

Author: TexasCoding

src/project_x_py/__init__.py

@@ -95,7 +95,7 @@
 
 from project_x_py.client.base import ProjectXBase
 
-__version__ = "3.1.3"
+__version__ = "3.1.4"
 __author__ = "TexasCoding"
 
 # Core client classes - renamed from Async* to standard names

src/project_x_py/realtime/core.py

@@ -232,6 +232,9 @@ def __init__(
             - Both hubs must connect successfully for full functionality
             - SignalR connections are established lazily on connect()
         """
+        # Initialize parent mixins
+        super().__init__()
+
         self.jwt_token = jwt_token
         self.account_id = account_id
 
@@ -274,8 +277,9 @@ def __init__(
         self.market_connected = False
         self.setup_complete = False
 
-        # Event callbacks (pure forwarding, no caching)
-        self.callbacks: defaultdict[str, list[Any]] = defaultdict(list)
+        # Event callbacks (pure forwarding, no caching) - already initialized in mixin
+        if not hasattr(self, "callbacks"):
+            self.callbacks: defaultdict[str, list[Any]] = defaultdict(list)
 
         # Basic statistics (no business logic)
         self.stats = {
@@ -295,9 +299,8 @@ def __init__(
         self.logger.info(f"User Hub: {final_user_url}")
         self.logger.info(f"Market Hub: {final_market_url}")
 
-        # Async locks for thread-safe operations
-        self._callback_lock = asyncio.Lock()
-        self._connection_lock = asyncio.Lock()
-
-        # Store the event loop for cross-thread task scheduling
-        self._loop: asyncio.AbstractEventLoop | None = None
+        # Async locks for thread-safe operations - check if not already initialized
+        if not hasattr(self, "_callback_lock"):
+            self._callback_lock = asyncio.Lock()
+        if not hasattr(self, "_connection_lock"):
+            self._connection_lock = asyncio.Lock()