� yo4h��L�ddlmZmZmZddlZGd�d��Zdedefd�ZdS)�)�List�Union�TupleNc�<�eZdZdeeeffd�Zd�Zd�Zd�Z dS)�AsyncIterate�datac�.�t|��|_dS�N)�iter�queue��selfrs �V/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/utils/async_utils.py�__init__zAsyncIterate.__init__s��$�Z�Z�� c��|Sr �)rs r� __aiter__zAsyncIterate.__aiter__ s��rc��PK�|��d{V��}|�|St�r )� fetch_data�StopAsyncIterationr s r� __anext__zAsyncIterate.__anext__s8��_�_�&�&�&�&�&�&�&�&��K�$�$rc��ZK� t|j��}n#t$rd}YnwxYw|Sr )�nextr� StopIteration)r�items rrzAsyncIterate.fetch_datasE�� #�#�D�D�� D�D�D� ��s��(�(N) �__name__� __module__�__qualname__rrrrrrrrrrrrse�� U�4��;�/� � � � ��%�%�%��rr�tasks�returnc��LK�tj|��d{V��}t|��Sr )�asyncio�gatherr)r �resultss rr$r$s2��N�E�*�*�*�*�*�*�*�G�� r)�typingrrrr#rr$rrr�r's��%�%�%�%�%�%�%�%�%�%��,!��!�,�!�!�!�!�!�!r