def METHOD_NAME(self, blocking=False, timeout=None):
    """Abort the ongoing connection."""
    if self._status == SplitSSEClient._Status.IDLE:
        _LOGGER.warning('sse already closed. ignoring')
        return
    self._client.shutdown()
    if blocking:
        self._sse_connection_closed.wait(timeout)