code: def _process_info(self, info_line):
          
          info = tornado.escape.json_decode(info_line.decode())
  
          if 'connect_urls' in info:
              if info['connect_urls']:
                  connect_urls = []
                  for connect_url in info['connect_urls']:
                      uri = urlparse("nats://%s" % connect_url)
                      srv = Srv(uri)
                      srv.discovered = True
  
                      # Filter for any similar server in the server pool already.
                      should_add = True
                      for s in self._server_pool:
                          if uri.netloc == s.uri.netloc:
                              should_add = False
                      if should_add:
                          connect_urls.append(srv)
  
                  if self.options["dont_randomize"] is not True:
                      shuffle(connect_urls)
                  for srv in connect_urls:
                      self._server_pool.append(srv)
docs: Process INFO lines sent by the server to reconfigure client
          with latest updates from cluster to enable server discovery.