def consume_next(self):
        read_rows_response = self._response_iterator.next()
        row_key = read_rows_response.row_key
        partial_row = self._rows.get(row_key)
        if partial_row is None:
            partial_row = self._rows[row_key] = PartialRowData(row_key)
        # NOTE: This is not atomic in the case of failures.
        partial_row.update_from_read_rows(read_rows_response)
Consumes the next ``ReadRowsResponse`` from the stream.
dataset/ETHPy150Open GoogleCloudPlatform/gcloud-python/gcloud/bigtable/row_data.py/PartialRowsData.consume_next