code: def _reconnect(self):
          
          self._wrapped = self._client.read_rows(
              _copy_stream_position(self._position), **self._read_rows_kwargs
          )
docs: Reconnect to the ReadRows stream using the most recent offset.