File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/__pycache__/future.cpython-310.pyc
o
�N�g
� @ s� d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl
Z ddl m
Z
mZ G dd� de�ZG d d
� d
e�ZG d d � d �ZG d
d� d�ZG dd� dee
�ZG dd� dee�Zee_G dd� de je �ZdS )zUFuture-returning APIs for tornado coroutines.
.. seealso::
:mod:`zmq.asyncio`
� N)�Any�Type)�Future)�IOLoop)� _AsyncPoller� _AsyncSocketc @ s e Zd ZdS )�CancelledErrorN)�__name__�
__module__� __qualname__� r r �H/opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/future.pyr s r c @ s e Zd ZdZdd� Zdd� ZdS )�_TornadoFuturez2Subclass Tornado Future, reinstating cancellation.c C s | � � rdS | �t� � dS )NFT)�doneZ
set_exceptionr ��selfr r r
�cancel s z_TornadoFuture.cancelc C s | � � o
t| �� t�S �N)r �
isinstance� exceptionr r r r r
� cancelled$ s z_TornadoFuture.cancelledN)r r
r �__doc__r r r r r r
r s r c @ � e Zd Zdd� Zdd� ZdS )�_CancellableTornadoTimeoutc C s || _ || _d S r )�loop�timeout)r r r r r r
�__init__) s
z#_CancellableTornadoTimeout.__init__c C s | j �| j� d S r )r Zremove_timeoutr r r r r
r - s z!_CancellableTornadoTimeout.cancelN)r r
r r r r r r r
r ( � r c @ s< e Zd ZU eZeej ed< e j
Z e j Z
dd� Zdd� ZdS )�
_AsyncTornado�_Futurec C s t �� S r )r �currentr r r r
�
_default_loop9 s z_AsyncTornado._default_loopc C s | � � }|�||�}t||�S r )Z _get_loopZ
call_laterr )r �delay�callback�io_loopr r r r
� _call_later< s
z_AsyncTornado._call_laterN)r r
r r r r �asyncior �__annotations__r ZREADZ_READZWRITEZ_WRITEr! r% r r r r
r 4 s
r c @ r )�Pollerc s |� |� fdd�|� dS )z"Schedule callback for a raw socketc s � � S r r )�args��fr r
�<lambda>E s z*Poller._watch_raw_socket.<locals>.<lambda>N)Z add_handler)r r �socketZevtr+ r r* r
�_watch_raw_socketC s zPoller._watch_raw_socketc G s |D ]}|� |� qdS )z$Unschedule callback for a raw socketN)Zremove_handler)r r Zsocketsr- r r r
�_unwatch_raw_socketsG s �zPoller._unwatch_raw_socketsN)r r
r r. r/ r r r r
r( B r r( c @ s e Zd ZeZdS )�SocketN)r r
r r( Z
_poller_classr r r r
r0 M s r0 c sB e Zd ZdZdZedd� �Zdd dededdf� fdd � Z� Z S )
�ContextNc C s
t | |�S r )r0 )r Z socket_typer r r
�
_socket_class[ s
zContext._socket_classr r) �kwargs�returnc sD |� dd �}|d urtj| jj� d�tdd� t� j|i |�� d S )Nr$ 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) r3 r$ �r: r r
r _ s �zContext.__init__)
r r
r Z _instancer$ � staticmethodr2 r r �
__classcell__r r r= r
r1 T s
&r1 )r r& r8 �typingr r Ztornado.concurrentr Ztornado.ioloopr ZzmqZ_zmqZ zmq._futurer r � Exceptionr r r r r( r0 r2 r1 r r r r
�<module> s