'Clear the connection pool and stop the monitor.
Reconnect with open().'

def close(self):

    if self._publish:
        self._events.put((self._listener.publish_server_closed, (self._description.address, self._topology_id)))
    self._monitor.close()
    self._pool.reset()
