def handle_connection_success(self, conn):
        self.conns.add(conn)
        self.conn_workers[conn] = gevent.spawn(self._listen, conn)

        if str(conn) not in self.nsqd_tcp_addresses:
            return

        self.conn_backoffs[conn].success()
dataset/ETHPy150Open wtolson/gnsq/gnsq/reader.py/Reader.handle_connection_success/original