@tasklets.tasklet<EOL><INDENT>def _fetch_page_async(self, page_size, **q_options):<DEDENT>
q_options.setdefault('<STR_LIT>', page_size)<EOL>q_options.setdefault('<STR_LIT>', True)<EOL>it = self.iter(limit=page_size + <NUM_LIT:1>, **q_options)<EOL>results = []<EOL>while (yield it.has_next_async()):<EOL><INDENT>results.append(next(it))<EOL>if len(results) >= page_size:<EOL><INDENT>break<EOL><DEDENT><DEDENT>try:<EOL><INDENT>cursor = it.cursor_after()<EOL><DEDENT>except datastore_errors.BadArgumentError:<EOL><INDENT>cursor = None<EOL><DEDENT>raise tasklets.Return(results, cursor, it.probably_has_next())<EOL>
Internal version of fetch_page_async().