B è?F[Êã@s$Gdd„deƒZGdd„deƒZdS)csZeZdZdZd‡fdd„ Zedd„ƒZdd„Zd d „Zd d „Z e Z d d„Z dd„Z ‡Z S)Ú ResultSeta¼ A class used to lazily handle page-to-page navigation through a set of results. It presents a transparent iterator interface, so that all the user has to do is use it in a typical ``for`` loop (or list comprehension, etc.) to fetch results, even if they weren't present in the current page of results. This is used by the ``Table.query`` & ``Table.scan`` methods. Example:: >>> users = Table('users') >>> results = ResultSet() >>> results.to_call(users.query, username__gte='johndoe') # Now iterate. When it runs out of results, it'll fetch the next page. >>> for res in results: ... print res['username'] NcsNtt|ƒ ¡d|_g|_i|_g|_d|_d|_d|_ d|_ ||_ d|_ dS)NéÿÿÿÿTé) ÚsuperrÚ__init__Ú the_callableÚ call_argsÚ call_kwargsÚ_resultsÚ_offsetÚ _results_leftÚ_last_key_seenÚ_fetchesÚ_max_page_sizeÚ_limit)ÚselfZ max_page_size)Ú __class__©ú5lib/python3.7/site-packages/boto/dynamodb2/results.pyrszResultSet.__init__cCsdS)NZexclusive_start_keyr)rrrrÚ first_key$szResultSet.first_keycCsg|_d|_dS)zº Resets the internal state of the ``ResultSet``. This prevents results from being cached long-term & consuming excess memory. Largely internal. rN)r r )rrrrÚ_reset(s zResultSet._resetcCs|S)Nr)rrrrÚ__iter__4szResultSet.__iter__cCs¢|jd7_|jt|jƒkrT|jdkr.tƒ‚| ¡xt|jƒsR|jrR| ¡q8W|jt|jƒkr˜|jdk rŒ|jd8_|jdkrŒtƒ‚|j|jStƒ‚dS)NéFr)r Úlenr r Ú StopIterationÚ fetch_morer)rrrrÚ__next__7s     zResultSet.__next__cOsNt|ƒstdƒ‚| dd¡|_|jdk r8|jdkr8d|_||_||_||_dS)aê Sets up the callable & any arguments to run it with. This is stored for subsequent calls so that those queries can be run without requiring user intervention. Example:: # Just an example callable. >>> def squares_to(y): ... for x in range(1, y): ... yield x**2 >>> rs = ResultSet() # Set up what to call & arguments. >>> rs.to_call(squares_to, y=3) z3You must supply an object or function to be called.ÚlimitNr)ÚcallableÚ ValueErrorÚpoprrrr)rrÚargsÚkwargsrrrÚto_callSszResultSet.to_callcCs | ¡|jdd…}|j ¡}|jdk r6|j||j<|jrV|jrV|j|jkrV|j|_|jdk rl|j|d<n|jdk r€|j|d<|j||Ž}|j d7_ |  dg¡}|  dd¡|_t |ƒrÌ|j   |d¡|jdk r |jdkr |j}|t |dƒ8}|dkr d|_|jdkrd|_dS)z¯ When the iterator runs out of results, this method is run to re-execute the callable (& arguments) to fetch the next page. Largely internal. NrrÚresultsZlast_keyrF)rrrÚcopyr rrrrr Úgetrr Úextendr )rr r!r#Z new_resultsrrrrrvs0           zResultSet.fetch_more)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚpropertyrrrrÚnextr"rÚ __classcell__rr)rrrs  #rcs$eZdZ‡fdd„Zdd„Z‡ZS)ÚBatchGetResultSetcs2| dg¡|_| dd¡|_tt|ƒj||ŽdS)NÚkeysZ max_batch_getéd)rÚ _keys_leftÚ_max_batch_getrr.r)rr r!)rrrr¨szBatchGetResultSet.__init__cCsô| ¡|jdd…}|j ¡}|jd|j…|d<|j|jd…|_t|jƒdkrZd|_|j||Ž}t|  dg¡ƒszdS|j   |d¡x*t |  dg¡ƒD]\}}|j  ||¡qœWt|jƒdkrÊd|_|j  d¡rð|jdt|dƒ8<dS)Nr/rFr#Zunprocessed_keysTr)rrrr$r1r2rr rr%r r&Ú enumerateÚinsert)rr r!r#ÚoffsetZkey_datarrrr­s"   zBatchGetResultSet.fetch_more)r'r(r)rrr-rr)rrr.§s r.N)Úobjectrr.rrrrÚs'