← Back
Editing: future.cpython-311.pyc
� mc�c � �B � d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl Z ddl m Z mZ G d� de� � Z G d � d e� � Z G d � d � � Z G d � d� � Z G d� dee � � Z G d� dee� � Zee_ G d� de j e � � ZdS )zUFuture-returning APIs for tornado coroutines. .. seealso:: :mod:`zmq.asyncio` � N)�Any�Type)�Future)�IOLoop)� _AsyncPoller� _AsyncSocketc � � e Zd ZdS )�CancelledErrorN)�__name__� __module__� __qualname__� � �6/usr/lib/python3/dist-packages/zmq/eventloop/future.pyr r s � � � � � ��Dr r c � � e Zd ZdZd� Zd� ZdS )�_TornadoFuturez2Subclass Tornado Future, reinstating cancellation.c �t � | � � � rdS | � t � � � � dS )NFT)�done� set_exceptionr ��selfs r �cancelz_TornadoFuture.cancel s6 � � �9�9�;�;� ��5� ���>�+�+�,�,�,��tr c �x � | � � � o&t | � � � t � � S �N)r � isinstance� exceptionr r s r � cancelledz_TornadoFuture.cancelled$ s) � ��y�y�{�{�K�z�$�.�.�*:�*:�N� K� K�Kr N)r r r �__doc__r r r r r r r s= � � � � � �<�<�� � � L� L� L� L� Lr r c � � e Zd Zd� Zd� ZdS )�_CancellableTornadoTimeoutc �" � || _ || _ d S r )�loop�timeout)r r" r# s r �__init__z#_CancellableTornadoTimeout.__init__) s � ��� � �� � � r c �D � | j � | j � � d S r )r" �remove_timeoutr# r s r r z!_CancellableTornadoTimeout.cancel- s � � � � � �� �.�.�.�.�.r N)r r r r$ r r r r r r ( s2 � � � � � � � � �/� /� /� /� /r r c �\ � e Zd ZU eZeej ed< e j Z e j Z d� Zd� ZdS )� _AsyncTornado�_Futurec �( � t j � � S r )r �currentr s r � _default_loopz_AsyncTornado._default_loop9 s � ��~� � � r c �v � | � � � }|� ||� � }t ||� � S r )� _get_loop� call_laterr )r �delay�callback�io_loopr# s r � _call_laterz_AsyncTornado._call_later< s6 � ��.�.�"�"���$�$�U�H�5�5��)�'�7�;�;�;r N)r r r r r) r �asyncior �__annotations__r �READ�_READ�WRITE�_WRITEr, r3 r r r r( r( 4 sY � � � � � � �$2�G�T�'�.� !�2�2�2� �K�E� �\�F� � � �<� <� <� <� <r r( c � � e Zd Zd� Zd� ZdS )�Pollerc �< �� |� |�fd�|� � dS )z"Schedule callback for a raw socketc � �� �� � S r r )�args�fs �r �<lambda>z*Poller._watch_raw_socket.<locals>.<lambda>E s �� �q�q�s�s� r N)� add_handler)r r" �socket�evtr? s `r �_watch_raw_socketzPoller._watch_raw_socketC s+ �� � ����!2�!2�!2�!2�C�8�8�8�8�8r c �: � |D ]}|� |� � �dS )z$Unschedule callback for a raw socketN)�remove_handler)r r" �socketsrB s r �_unwatch_raw_socketszPoller._unwatch_raw_socketsG s2 � � � (� (�F� � � �� '� '� '� '� (� (r N)r r r rD rH r r r r; r; B s2 � � � � � �9� 9� 9�(� (� (� (� (r r; c � � e Zd ZeZdS )�SocketN)r r r r; � _poller_classr r r rJ rJ M s � � � � � ��M�M�Mr rJ c �N � � e Zd ZdZdZed� � � Zdd dededdf� fd� Z� xZ S )�ContextNc �" � t | |� � S r )rJ )r � socket_types r � _socket_classzContext._socket_class[ s � ��d�K�(�(�(r r r> �kwargs�returnc � �� |� dd � � }|�)t j | j j � d�t d�� � t � � j |i |�� d S )Nr2 z^(io_loop) argument is deprecated in pyzmq 22.2. The currently active loop will always be used.� )� stacklevel)�pop�warnings�warn� __class__r �DeprecationWarning�superr$ )r r> rQ r2 rY s �r r$ zContext.__init___ sy �� ��*�*�Y��-�-�� � � �M��>�*� B� B� B�"� � � � � � �����$�)�&�)�)�)�)�)r ) r r r � _instancer2 � staticmethodrP r r$ � __classcell__)rY s @r rM rM T s~ �� � � � � � �I��G��)� )� �\�)� *�y� *�� *�� *�� *� *� *� *� *� *� *� *� *� *r rM )r r4 rW �typingr r �tornado.concurrentr �tornado.ioloopr �zmq�_zmq� zmq._futurer r � Exceptionr r r r( r; rJ rP rM r r r �<module>rf s� ��� � ���� ���� � � � � � � � � %� %� %� %� %� %� !� !� !� !� !� !� � � � � 2� 2� 2� 2� 2� 2� 2� 2� � � � � �Y� � � � L� L� L� L� L�V� L� L� L�/� /� /� /� /� /� /� /� <� <� <� <� <� <� <� <� (� (� (� (� (�]�L� (� (� (�� � � � �]�L� � � � �� �*� *� *� *� *�d�l�6�"� *� *� *� *� *r
Save File
Cancel