File: //proc/thread-self/root/lib64/python3.6/site-packages/zmq/__pycache__/asyncio.cpython-36.pyc
3
VS�_�
�
@ s� d Z ddlZddlmZ ddlZddlmZmZ y ddlZW n ek
r\ ddlmZ Y nX G dd� de �Z
G dd � d e
ej �Z G d
d � d e
ej
�Zee _G d d
� d
ej�ZG dd� de�ZdZdd� Zde_dd� Zd
d d ddgZdS )z8AsyncIO support for zmq
Requires asyncio and Python 3.
� N)�_future)�SelectorEventLoop�Future)� selectorsc @ s$ e Zd ZeZejZejZ dd� Z
dS )�_AsyncIOc C s t j� S )N)�asyncioZget_event_loop)�self� r � /usr/lib64/python3.6/asyncio.py�
_default_loop s z_AsyncIO._default_loopN) �__name__�
__module__� __qualname__r Z_Futurer Z EVENT_WRITE�_WRITEZ
EVENT_READ�_READr r r r r
r s r c @ s e Zd ZdZdd� Zdd� ZdS )�Pollerz1Poller returning asyncio.Future for poll results.c s@ || j @ r |j|� fdd�� || j@ r<|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>c s � � S )Nr )r )r r r
r ( s N)r �
add_readerr Z
add_writer)r �loop�socketZevtr r )r r
�_watch_raw_socket# s
zPoller._watch_raw_socketc G s& x |D ]}|j |� |j|� qW dS )z$Unschedule callback for a raw socketN)�
remove_readerZ
remove_writer)r r Zsocketsr r r r
�_unwatch_raw_sockets* s
zPoller._unwatch_raw_socketsN)r r
r �__doc__r r r r r r
r s r c @ s$ e Zd ZdZeZdd� Zdd� ZdS )�Socketz<Socket returning asyncio Futures for send/recv/poll methods.c s � j j� j� fdd�� dS )z#initialize the ioloop event handlerc s � j dd�S )Nr )Z_handle_eventsr )r r r
r 8 s z'Socket._init_io_state.<locals>.<lambda>N)�io_loopr �_fd)r r )r r
�_init_io_state6 s zSocket._init_io_statec C s | j j| j� dS )zEclear any ioloop event handler
called once at close
N)r r r )r r r r
�_clear_io_state: s zSocket._clear_io_stateN)r r
r r r Z
_poller_classr r r r r r
r 1 s r c @ s e Zd ZdZeZdZdS )�Contextz/Context for creating asyncio-compatible SocketsN)r r
r r r �
_socket_classZ _instancer r r r
r! E s r! c s" e Zd ZdZd� fdd� Z� ZS )� ZMQEventLoopz}DEPRECATED: AsyncIO eventloop using zmq_poll.
pyzmq sockets should work with any asyncio event loop as of pyzmq 17.
Nc s t � tt| �j|�S )N)� _deprecated�superr# �__init__)r Zselector)� __class__r r
r& T s zZMQEventLoop.__init__)N)r r
r r r& �
__classcell__r r )r' r
r# N s r# c C s, t jr
d S dt _dd l} | jdtdd� d S )NTr zsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.� )�
stacklevel)r$ �called�warnings�warn�DeprecationWarning)r, r r r
r$ \ s r$ Fc C s
t � dS )z(DEPRECATED: No longer needed in pyzmq 17N)r$ r r r r
�installl s r/ )r ZzmqZ_zmqr r r r r � ImportError�objectr Z _AsyncPollerr Z _AsyncSocketr r" r! r# Z_loopr$ r+ r/ �__all__r r r r
�<module> s.