in pyignite/cursors.py [0:0]
def __next__(self):
if not self.data:
raise StopIteration
try:
k, v = next(self.data)
except StopIteration:
if self.more:
result = sql_cursor_get_page(self.connection, self.cursor_id)
if result.status != 0:
raise SQLError(result.message)
self.data, self.more = iter(result.value['data'].items()), result.value['more']
k, v = next(self.data)
else:
raise StopIteration
return self.client.unwrap_binary(k), self.client.unwrap_binary(v)