Method start

stream/proxy_server.py:457–473

Start the proxy server

(self)

                pass

    async def start(self) -> None:
        """
        Start the proxy server
        """
        server = await asyncio.start_server(self.handle_client, self.host, self.port)
        addr = server.sockets[0].getsockname()
        self.logger.debug(f"[Proxy] Serving on: {addr}")

        if self.queue:
            try:
                self.queue.put("READY")
                self.logger.debug("[Proxy] Sent READY signal")
            except Exception as e:
                self.logger.error(f"Failed to send 'READY' signal: {e}", exc_info=True)

        async with server:
            await server.serve_forever()