File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/eventloop/__pycache__/future.cpython-310.pyc
Back
o ;j4 � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ ddl m Z ddl Z ddl mZmZ G dd � d e�ZG d d � d e�ZG d d � d �ZG dd� d�ZG dd� dee�ZG dd� dee�Zee_G dd� de je �ZdS )zUFuture-returning APIs for tornado coroutines. .. seealso:: :mod:`zmq.asyncio` � )� annotationsN)�Any)�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 @ s6 e Zd ZU eZded< ejZej Z dd� Z dd� Z dS )� _AsyncTornadoztype[asyncio.Future]�_Futurec C s t �� S r )r �currentr r r r � _default_loop: 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 �__annotations__r ZREADZ_READZWRITEZ_WRITEr! r% r r r r r 5 s r c @ r )�Pollerc s |� |� fdd�|� dS )z"Schedule callback for a raw socketc s � � S r r )�args��fr r �<lambda>F s z*Poller._watch_raw_socket.<locals>.<lambda>N)Z add_handler)r r �socketZevtr* r r) r �_watch_raw_socketD 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_socketsH s �zPoller._unwatch_raw_socketsN)r r r r- r. r r r r r' C r r' c @ s e Zd ZeZdS )�SocketN)r r r r' Z _poller_classr r r r r/ N s r/ c s2 e Zd ZdZdZedd� �Zd � fd d � Z� ZS ) �ContextNc C s t | |�S r )r/ )r Z socket_typer r r � _socket_class[ s zContext._socket_classr r( r �kwargs�return�Nonec 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( r2 r$ �r: r r r _ s �zContext.__init__)r r0 r( r r2 r r3 r4 ) r r r Z _instancer$ � staticmethodr1 r � __classcell__r r r= r r0 U s r0 )r � __future__r Zasyncior8 �typingr Ztornado.concurrentr Ztornado.ioloopr ZzmqZ_zmqZ zmq._futurer r � Exceptionr r r r r' r/ r1 r0 r r r r �<module> s"
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings