관리-도구
편집 파일: async_utils.cpython-311.pyc
� �rb��`� �L � d dl mZmZmZ d dlZ G d� d� � Zdedefd�ZdS )� )�List�Union�TupleNc �< � e Zd Zdeeef fd�Zd� Zd� Zd� Z dS )� AsyncIterate�datac �. � t |� � | _ d S �N)�iter�queue��selfr s �V/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/utils/async_utils.py�__init__zAsyncIterate.__init__ s � ��$�Z�Z�� � � � c � � | S r � )r s r � __aiter__zAsyncIterate.__aiter__ s � �� r c � �P K � | � � � � d {V ��}|�|S t �r )� fetch_data�StopAsyncIterationr s r � __anext__zAsyncIterate.__anext__ s8 � � � ��_�_�&�&�&�&�&�&�&�&�� � ��K�$� $r c � �Z K � t | j � � }n# t $ r d }Y nw xY w|S r )�nextr � StopIteration)r �items r r zAsyncIterate.fetch_data sE � � � � ��� �#�#�D�D�� � � � ��D�D�D� ����� s � � (�(N) �__name__� __module__� __qualname__r r r r r r r r r r r r se � � � � � � �U�4��;� /� � � � �� � �%� %� %�� � � � r r �tasks�returnc � �L K � t j | � � d {V ��}t |� � S r )�asyncio�gatherr )r �resultss r r$ r$ s2 � � � ��N�E�*�*�*�*�*�*�*�G� �� � � r )�typingr r r r# r r$ r r r �<module>r' s� �� %� %� %� %� %� %� %� %� %� %� ����� � � � � � � �,!�� !�,� !� !� !� !� !� !r