We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 63b4324 commit edfefc8Copy full SHA for edfefc8
google/cloud/spanner_v1/streamed.py
@@ -42,7 +42,6 @@ class StreamedResultSet(object):
42
def __init__(self, response_iterator, source=None):
43
self._response_iterator = response_iterator
44
self._rows = [] # Fully-processed rows
45
- self._counter = 0 # Counter for processed responses
46
self._metadata = None # Until set from first PRS
47
self._stats = None # Until set from last PRS
48
self._current_row = [] # Accumulated values for incomplete row
@@ -114,7 +113,6 @@ def _consume_next(self):
114
113
Parse the result set into new/existing rows in :attr:`_rows`
115
"""
116
response = six.next(self._response_iterator)
117
- self._counter += 1
118
119
if self._metadata is None: # first response
120
metadata = self._metadata = response.metadata
0 commit comments