File: //lib64/python3.6/site-packages/zmq/eventloop/__pycache__/future.cpython-36.pyc
3
VS�_8 � @ s� d Z ddlZddlmZmZ ddlmZ ddlm Z G dd� de
�Z G dd � d e�Z G d
d � d e
�ZG d d
� d
ee�ZG dd� dee�Zee_G dd� dej�ZdS )zUFuture-returning APIs for tornado coroutines.
.. seealso::
:mod:`zmq.asyncio`
� N)� _AsyncPoller� _AsyncSocket)�Future)�IOLoopc @ s e Zd ZdS )�CancelledErrorN)�__name__�
__module__� __qualname__� r
r
� /usr/lib64/python3.6/future.pyr s r c @ s e Zd ZdZdd� Zdd� ZdS )�_TornadoFuturez2Subclass Tornado Future, reinstating cancellation.c C s | j � r dS | jt� � dS )NFT)�doneZ
set_exceptionr )�selfr
r
r �cancel s z_TornadoFuture.cancelc C s | j � ot| j� t�S )N)r
�
isinstanceZ exceptionr )r r
r
r � cancelled s z_TornadoFuture.cancelledN)r r r �__doc__r r r
r
r
r r s r c @ s$ e Zd ZeZejZejZ dd� Z
dS )�
_AsyncTornadoc C s t j� S )N)r �current)r r
r
r �
_default_loop' s z_AsyncTornado._default_loopN) r r r r Z_Futurer ZREADZ_READZWRITEZ_WRITEr r
r
r
r r # s r c @ s e Zd Zdd� Zdd� ZdS )�Pollerc s |j |� fdd�|� dS )z"Schedule callback for a raw socketc s � � S )Nr
)�args)�fr
r �<lambda>. s z*Poller._watch_raw_socket.<locals>.<lambda>N)Z add_handler)r �loop�socketZevtr r
)r r �_watch_raw_socket, s zPoller._watch_raw_socketc G s x|D ]}|j |� qW dS )z$Unschedule callback for a raw socketN)Zremove_handler)r r Zsocketsr r
r
r �_unwatch_raw_sockets0 s
zPoller._unwatch_raw_socketsN)r r r r r r
r
r
r r + s r c @ s e Zd ZeZdS )�SocketN)r r r r Z
_poller_classr
r
r
r r 6 s r c s0 e Zd ZdZdZedd� �Z� fdd�Z� ZS )�ContextNc C s t | || jd�S )N)�io_loop)r r )r Z socket_typer
r
r �
_socket_classA s zContext._socket_classc s0 |j dd �}tt| �j||� |p(tj� | _d S )Nr )�pop�superr �__init__r r r )r r �kwargsr )� __class__r
r r$ E s zContext.__init__) r r r Z _instancer � staticmethodr! r$ �
__classcell__r
r
)r& r r ; s r )r ZzmqZ_zmqZ zmq._futurer r Ztornado.concurrentr Ztornado.ioloopr � Exceptionr r �objectr r r r! r r
r
r
r �<module> s