yo4hLddlmZmZmZddlZGddZdedefdZdS))ListUnionTupleNc<eZdZdeeeffdZdZdZdZ dS) AsyncIteratedatac.t||_dSN)iterqueueselfrs V/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/utils/async_utils.py__init__zAsyncIterate.__init__s$ZZ c|Sr )rs r __aiter__zAsyncIterate.__aiter__ s rcPK|d{V}||Str ) fetch_dataStopAsyncIterationr s r __anext__zAsyncIterate.__anext__ s8__&&&&&&&&  K$ $rcZK t|j}n#t$rd}YnwxYw|Sr )nextr StopIteration)ritems rrzAsyncIterate.fetch_datasE  ##DD   DDD  s  ((N) __name__ __module__ __qualname__rrrrrrrrrrrrse U4;/    %%%rrtasksreturncLKtj|d{V}t|Sr )asynciogatherr)r resultss rr$r$s2NE*******G   r)typingrrrr#rr$rrrr's%%%%%%%%%%,!!,!!!!!!r