query_set.py 文件源码

def iter(self, conn):
        """ Return an iterator over all of the objects return by the query.

        :param conn: Cassandra connection wrapper used to execute the query.
        :type: cqlengine.ConnectionInterface subclass
        """
        self._execute_query(conn)

        idx = 0
        while True:
            if len(self._result_cache) <= idx:
                try:
                    self._result_cache.append(next(self._result_generator))
                except StopIteration:
                    break

            instance = self._result_cache[idx]
            if isinstance(instance, dict):
                self._fill_result_cache_to_idx(conn, idx)
            yield self._result_cache[idx]

            idx += 1