"""Decode a ResultMessage lazily using a generator"""

cpdef parse_rows(self, BytesIOReader reader, ParseDesc desc):

# Use a little helper function as closures (generators) are not

# supported in cpdef methods

"""

cpdef unpack_row(self, BytesIOReader reader, ParseDesc desc):

assert desc.rowsize >= 0

cdef Buffer buf

cdef Py_ssize_t i, rowsize = desc.rowsize

cdef Deserializer deserializer

cdef tuple res = tuple_new(desc.rowsize)

for i in range(rowsize):

# Read the next few bytes

get_buf(reader, &buf)

# Deserialize bytes to python object

deserializer = desc.deserializers[i]

try:

val = from_binary(deserializer, &buf, desc.protocol_version)

except Exception as e:

raise DriverException('Failed decoding result column "%s" of type %s: %s' % (desc.colnames[i],

desc.coltypes[i].cql_parameterized_type(),

str(e)))

# Insert new object into tuple

tuple_set(res, i, val)