fix: run subscribes on main thread

soar_bus.py

@@ -118,19 +118,15 @@ def run_client(client_id, executor):
         )
         THREADS[f"{client_id}-broadcast"] = thread
 
-        # subscribe
-        thread = executor.submit(
-            subscribe,
+        subscribe(
             f"{client_id}-inbox",
             EXCHANGES.get("publish"),
-            client["subscription"],  # topic
+            client["subscription"],
         )
-        THREADS[f"{client_id}-inbox-published"] = thread
-
-        thread = executor.submit(
-            subscribe, f"{client_id}-inbox", EXCHANGES.get("broadcast")
+        subscribe(
+            f"{client_id}-inbox", 
+            EXCHANGES.get("broadcast")
         )
-        THREADS[f"{client_id}-inbox-broadcast"] = thread
         if client_id not in RUNNING_CLIENTS:
             RUNNING_CLIENTS.append(client_id)
         running = True