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