#NEWLINE# def consume_next( self ) : #NEWLINE# #INDENT# 'Consumes the next ``ReadRowsResponse`` from the stream.\n\n        Parses the response and stores it as a :class:`PartialRowData`\n        in a dictionary owned by this object.\n\n        :raises: :class:`StopIteration <exceptions.StopIteration>` if the\n                 response iterator has no more responses to stream.\n        ' #NEWLINE# read_rows_response = self . _response_iterator . next ( ) #NEWLINE# row_key = read_rows_response . row_key #NEWLINE# partial_row = self . _rows . get ( row_key ) #NEWLINE# if ( partial_row is None ) : #NEWLINE# #INDENT# partial_row = self . _rows [ row_key ] = PartialRowData ( row_key ) #NEWLINE# #UNINDENT# partial_row . update_from_read_rows ( read_rows_response )