def publish_connection_closed(self, address, connection_id, reason):
        """Publish a :class:`ConnectionClosedEvent` to all connection
        listeners.
        """
        event = ConnectionClosedEvent(address, connection_id, reason)
        for subscriber in self.__cmap_listeners:
            try:
                subscriber.connection_closed(event)
            except Exception:
                _handle_exception()
Publish a :class:`ConnectionClosedEvent` to all connection
        listeners.
        
stackoverflow/venv/lib/python3.6/site-packages/pymongo/monitoring.py