← Back
Editing: timeout.cpython-311.pyc
� "z�c+ � �X � d dl Z d dlZd dlmZ d dlmZ d dlmZmZ G d� d� � ZdS )� N)� TracebackType)�Any)�Optional�Typec �" � e Zd ZdZdd�d ee deej ddfd�Zdd�Z de e d e d e dee fd �Zdd �Zde e d e d e ddfd �Zede fd�� � Zedee fd�� � Zdd�Zde e ddfd�Zdd�ZdS )�timeouta� timeout context manager. Useful in cases when you want to apply timeout logic around block of code or in cases when asyncio.wait_for is not suitable. For example: >>> with timeout(0.001): ... async with aiohttp.get('https://github.com') as r: ... await r.text() timeout - value in seconds or None to disable timeout logic loop - asyncio compatible event loop N)�loopr �returnc � � || _ |�t j � � }nt j dt � � || _ d | _ d| _ d | _ d | _ d S )Nz-The loop argument to timeout() is deprecated.F) �_timeout�asyncio�get_running_loop�warnings�warn�DeprecationWarning�_loop�_task� _cancelled�_cancel_handler� _cancel_at)�selfr r s �1/usr/lib/python3/dist-packages/asgiref/timeout.py�__init__ztimeout.__init__ sd � � �� � �<��+�-�-�D�D� �M�C�EW� � � � �� ��� � ��� #�� � ����� c �* � | � � � S �N�� _do_enter�r s r � __enter__ztimeout.__enter__2 s � ��~�~� � � r �exc_type�exc_val�exc_tbc �0 � | � |� � d S r ��_do_exit�r r! r" r# s r �__exit__ztimeout.__exit__5 s � � � � �h� � � ��tr c � �. K � | � � � S r r r s r � __aenter__ztimeout.__aenter__> s � � � ��~�~� � � r c � �4 K � | � |� � d S r r% r' s r � __aexit__ztimeout.__aexit__A s � � � � � � �h� � � � � r c � � | j S r )r r s r �expiredztimeout.expiredI s � ��� r c �r � | j �/t | j | j � � � z d� � S d S )Ng )r �maxr �timer s r � remainingztimeout.remainingM s2 � � �?� &��t���� � �):�):�:�C�@�@� @��4r c �x � | j �| S t j | j � � | _ | j �t d� � �| j dk r!| j � | j � � | S | j � � � | j z | _ | j � | j | j � � | _ | S )Nz4Timeout context manager should be used inside a taskr ) r r � current_taskr r � RuntimeError� call_soon� _cancel_taskr1 r �call_atr r s r r ztimeout._do_enterT s� � � �=� ��K� �)�$�*�5�5�� � �:� � �I�� � � �=�A� � � �J� � ��!2� 3� 3� 3��K� �*�/�/�+�+�d�m�;��� #�z� 1� 1�$�/�4�CT� U� U�� �� r c �� � |t j u r!| j rd | _ d | _ t j �| j �'| j � | j � � � d | _ d | _ d S r )r �CancelledErrorr r r � TimeoutErrorr �cancel)r r! s r r& ztimeout._do_exith sh � � �w�-� -� -�$�/� -�#'�D� � �D�J��&� &� �=� $��)=�)I� � � '� '� )� )� )�#'�D� ��� ��tr c �X � | j �"| j � � � d| _ d S d S )NT)r r< r r s r r7 ztimeout._cancel_tasks s1 � � �:� !� �J� � � � � � "�D�O�O�O� "� !r )r r )r N)�__name__� __module__� __qualname__�__doc__r �floatr �AbstractEventLoopr r r � BaseExceptionr �boolr( r* r, �propertyr. r2 r r& r7 � r r r r s� � � � � � � � �$ 59� � � ��%� � � �w�0�1� � � � � � �& � � � ���}�%�� �� � � �$� � � � � � � � � � ��}�%� � � � � � � � � � � � �� � � � �X� � ��8�E�?� � � � �X�� � � � �( ��m�!4� �� � � � �#� #� #� #� #� #r r ) r r �typesr �typingr r r r rG r r �<module>rJ s� �� ���� ���� � � � � � � � � � � � � !� !� !� !� !� !� !� !�f#� f#� f#� f#� f#� f#� f#� f#� f#� f#r
Save File
Cancel