| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Sorry, something went wrong.
| def __init__(self, response_iterator, source=None): | ||
| self._response_iterator = response_iterator | ||
| self._rows = [] # Fully-processed rows | ||
| self._processed_rows = [] # Fully-processed rows |
| while True: | ||
| try: | ||
| streamed.consume_next() | ||
| streamed._consume_next() |
| retrieved += len(streamed.rows) | ||
| streamed.rows[:] = () | ||
| retrieved += len(streamed._rows) | ||
| streamed._rows[:] = () |
There was a problem hiding this comment.
Let's just delete the two system tests: they are redundant with those in other testcases.
Sorry, something went wrong.
|
|
||
| @property | ||
| def rows(self): | ||
| def _rows(self): |
| self._merge_values(values) | ||
|
|
||
| def consume_all(self): | ||
| def _consume_all(self): |
Sorry, something went wrong.
| self.assertIsNone(result_set._source) | ||
|
|
||
| result_set._consume_all() | ||
| # result_set._consume_all() |
| # result_set._consume_all() | ||
|
|
||
| self.assertEqual(list(result_set._rows), VALUES) | ||
| self.assertEqual(list(result_set), VALUES) |
|
I just changed the _rows to list. I will put that in another PR. |
Sorry, something went wrong.
* Spanner: Make rows, consume_all and consume_next private * review changes * Spanner: remove _consume_all and _rows methods * Spanner: delete unnecessary tests
| Back | FazBrowse Home | New Git URL |
See #4414 and #4204