U 3ì dÊã@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__©ú:/tmp/pip-unpacked-wheel-d7dsrkjd/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)NrrrrrÚ__iter__4szResultSet.__iter__cCsž|jd7_|jt|jƒkrP|jdkr.tƒ‚| ¡t|jƒsP|jrP| ¡q6|jt|jƒkr”|jdk rˆ|jd8_|jdkrˆtƒ‚|j|jStƒ‚dS)NéFr)r Úlenr r Ú StopIterationÚ fetch_morerrrrrÚ__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_callSsÿzResultSet.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__rrrrrs   #rcs$eZdZ‡fdd„Zdd„Z‡ZS)ÚBatchGetResultSetcs2| dg¡|_| dd¡|_tt|ƒj||ŽdS)NÚkeysZ max_batch_getéd)r!Ú _keys_leftÚ_max_batch_getrr0r)rr"r#rrrr¨szBatchGetResultSet.__init__cCsð| ¡|jdd…}|j ¡}|jd|j…|d<|j|jd…|_t|jƒdkrZd|_|j||Ž}t|  dg¡ƒszdS|j   |d¡t |  dg¡ƒD]\}}|j  ||¡qšt|jƒdkrÆd|_|j  d¡rì|jdt|dƒ8<dS)Nr1rFr%Zunprocessed_keysTr)rrrr&r3r4rr rr'r r(Ú enumerateÚinsert)rr"r#r%ÚoffsetZkey_datarrrr­s"   zBatchGetResultSet.fetch_more)r)r*r+rrr/rrrrr0§s r0N)Úobjectrr0rrrrÚs'