async def _connect_websocket(self):
        """Implement service-specific websocket connection logic. This function
        should only connect to the websocket."""
        pass
Implement service-specific websocket connection logic. This function
        should only connect to the websocket.
src/pipecat/services/websocket_service.py