Merge branch 'master' into opentelemetry-tracing

google/cloud/spanner_v1/snapshot.py

@@ -436,7 +436,7 @@ class Snapshot(_SnapshotBase):
     at a timestamp where all previously committed transactions are visible.
 
     :type session: :class:`~google.cloud.spanner_v1.session.Session`
-    :param session: the session used to perform the commit.
+    :param session: The session used to perform the commit.
 
     :type read_timestamp: :class:`datetime.datetime`
     :param read_timestamp: Execute all reads at the given timestamp.
@@ -454,7 +454,7 @@ class Snapshot(_SnapshotBase):
                             ``exact_staleness`` old.
 
     :type multi_use: :class:`bool`
-    :param multi_use: If true, multipl :meth:`read` / :meth:`execute_sql`
+    :param multi_use: If true, multiple :meth:`read` / :meth:`execute_sql`
                       calls can be performed with the snapshot in the
                       context of a read-only transaction, used to ensure
                       isolation / consistency. Incompatible with

google/cloud/spanner_v1/streamed.py

@@ -42,7 +42,6 @@ class StreamedResultSet(object):
     def __init__(self, response_iterator, source=None):
         self._response_iterator = response_iterator
         self._rows = []  # Fully-processed rows
-        self._counter = 0  # Counter for processed responses
         self._metadata = None  # Until set from first PRS
         self._stats = None  # Until set from last PRS
         self._current_row = []  # Accumulated values for incomplete row
@@ -114,7 +113,6 @@ def _consume_next(self):
         Parse the result set into new/existing rows in :attr:`_rows`
         """
         response = six.next(self._response_iterator)
-        self._counter += 1
 
         if self._metadata is None:  # first response
             metadata = self._metadata = response.metadata