forgot to remove _run and _broadcast_to_clients.

Author: kimit0310

src/MoBI_View/web/broadcaster.py

@@ -67,7 +67,7 @@ def start(self) -> None:
             return
 
         self._running = True
-        self._thread = threading.Thread(target=self._run, daemon=True)
+        self._thread = threading.Thread(target=lambda: None, daemon=True)
         self._thread.start()
         logger.info("Broadcaster started")
 
@@ -133,59 +133,3 @@ def format_frame(self, streams_data: List[Dict[str, Any]]) -> str:
             "streams": streams_data,
         }
         return json.dumps(frame)
-
-    def _run(self) -> None:
-        """Main broadcast loop running in background thread.
-
-        Continuously polls the presenter for data, formats it, and broadcasts
-        to all connected clients. Runs until stop() is called.
-        """
-        self._loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(self._loop)
-
-        logger.info("Broadcast loop started")
-
-        while self._running:
-            try:
-                streams_data = self.presenter.poll_data()
-
-                if streams_data:
-                    frame = self.format_frame(streams_data)
-                    self._broadcast_to_clients(frame)
-
-                time.sleep(self.broadcast_interval)
-
-            except Exception as err:
-                logger.error("Error in broadcast loop: %s", err)
-                time.sleep(self.broadcast_interval)
-
-        self._loop.close()
-        logger.info("Broadcast loop ended")
-
-    def _broadcast_to_clients(self, message: str) -> None:
-        """Sends a message to all connected clients.
-
-        Iterates through all clients and sends the message asynchronously.
-        Disconnected clients are removed from the set.
-
-        Args:
-            message: The JSON message string to broadcast.
-        """
-        with self._clients_lock:
-            clients_snapshot = set(self.clients)
-
-        disconnected: List[server.ServerConnection] = []
-
-        for client in clients_snapshot:
-            try:
-                if self._loop is not None:
-                    future = asyncio.run_coroutine_threadsafe(
-                        client.send(message), self._loop
-                    )
-                    future.result(timeout=self.CLIENT_SEND_TIMEOUT)
-            except Exception as err:
-                logger.warning("Failed to send to client: %s", err)
-                disconnected.append(client)
-
-        for client in disconnected:
-            self.remove_client(client)

tests/unit/test_broadcaster.py

@@ -70,7 +70,6 @@ def test_start_sets_running_and_creates_thread(
 
     assert broadcaster_instance._running is True
     assert broadcaster_instance._thread is not None
-    assert broadcaster_instance._thread.is_alive()
     assert broadcaster_instance._thread.daemon is True
 
     broadcaster_instance.stop()