]hddlZddlZddlmZmZmZmZmZm Z m Z m Z ddl m Z ejeZedZedZddgZGd d eeZGd deeeZGd deeZy) N)Iterable AsyncIteratorTypeVarCallableTupleOptional AwaitableAny) AzureError ReturnType ResponseTypeAsyncPageIteratorAsyncItemPagedc.eZdZdeeddfdZdefdZy) AsyncListiterablereturnNc$t||_y)zChange an iterable into a fake async iterator. Could be useful to fill the async iterator contract when you get a list. :param iterable: A sync iterable of T N)iter _iterator)selfrs ]/var/www/core.comfia.cic-ware.com/crm/lib/python3.12/site-packages/azure/core/async_paging.py__init__zAsyncList.__init__3shcnK t|jS#t$r}t|d}~wwxYwwN)nextr StopIterationStopAsyncIteration)rerrs r __anext__zAsyncList.__anext__>s4 0' ' 0$&C / 0s55 2 -25)__name__ __module__ __qualname__rr rr"rrrr2s& (*!5 ($ (00rrc zeZdZ ddeeegeefdeegeeee e ffdeeddfdZ de e fdZ y) rNget_next extract_datacontinuation_tokenrcX||_||_||_d|_d|_d|_y)a_Return an async iterator of pages. :param get_next: Callable that take the continuation token and return a HTTP response :param extract_data: Callable that take an HTTP response and return a tuple continuation token, list of ReturnType :param str continuation_token: The continuation token needed by get_next FN) _get_next _extract_datar*_did_a_call_already _response _current_page)rr(r)r*s rrzAsyncPageIterator.__init__Fs2")"4#( 15BFrcK|j|jr td |j|jd{|_d|_|j |jd{\|_|_t|jtjjrt|j|_|jS7#t $r#}|js|j|_d}~wwxYw7w)Nz End of pagingT) r*r.r r,r/r r-r0 isinstance collectionsabcrr)rerrors rr"zAsyncPageIterator.__anext__Zs  " " *t/G/G$_5 5 #'>>$2I2I#JJDN $( <@D !!!K +++/+B+B(  7_sG$D CC C%D 4D 5A%D C D%DDD r) r#r$r%rrstrr rrrr rr"r&rrrrEs -1 GHSM?Il,CCDG ~ysMR\D]?]9^/__`G%SM G  G("z!:"rcReZdZdededdfdZ d deedeeefdZ defdZ y) rargskwargsrNc||_||_d|_d|_|jj dt |_y)zReturn an async iterator of items. args and kwargs will be passed to the AsyncPageIterator constructor directly, except page_iterator_class Npage_iterator_class)_args_kwargs_page_iterator_pagepopr_page_iterator_class)rr8r9s rrzAsyncItemPaged.__init__ps<   RV:> $(LL$4$45JL]$^!rr*cV|j|ji|jd|iS)aGet an async iterator of pages of objects, instead of an async iterator of objects. :param str continuation_token: An opaque continuation token. This value can be retrieved from the continuation_token field of a previous generator object. If specified, this generator will begin returning results from this point. :returns: An async iterator of pages (themselves async iterator of objects) :rtype: AsyncIterator[AsyncIterator[ReturnType]] r*)rAr<r=)rr*s rby_pagezAsyncItemPaged.by_page|s*)t(($**l lYkllrcK|j-|j|_|jd{S|j?|jjd{|_|jd{S |jjd{S7r7F7+7 #t$r#d|_|jd{7cYSwxYwwr)r>rCr"r?r )rs rr"zAsyncItemPaged.__anext__s    &"&,,.D )) ) :: #22<<>>DJ)) ) *--// / *?)/! *DJ))) ) *su5C!B*-C!%B,&C!B.C!B2%B0&B2)C!,C!.C!0B22#CCCC!CC!r) r#r$r%r rrr6rr rCr"r&rrrrosY _c _S _T _-1 m$SM m }Z0 1 m * *r)collections.abcr3loggingtypingrrrrrrr r exceptionsr getLoggerr#_LOGGERr r__all__rrrr&rrrLs4   # '  H % \ " ~&  0 10 j)0&'" mJ&?@'"T(*]:.(*r