async def _receive_messages(self):
        """Implement service-specific message receiving logic."""
        pass
Implement service-specific message receiving logic.
src/pipecat/services/websocket_service.py