File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/auth/__pycache__/asyncio.cpython-310.pyc
o
�N�g� � @ s^ d Z ddlZddlZddlmZmZ ddlZddlmZ ddl m
Z
G dd� de
�Z dgZ dS ) zOZAP Authenticator integrated with the asyncio IO loop.
.. versionadded:: 15.2
� N)�Any�Optional)�Poller� )�
Authenticatorc st e Zd ZU dZee ed< eed< ded< dded d ef� fd
d �
Zdd
d�Z d� fdd� Z
d� fdd� Z � Z S )�AsyncioAuthenticatorz1ZAP authentication for use in the asyncio IO loop� _AsyncioAuthenticator__poller�_AsyncioAuthenticator__taskzzmq.asyncio.Socket�
zap_socketN�contextz zmq.Context�loopc s8 t � �|� |d urt�| jj� d�� d | _d | _d S )Nz (loop) is deprecated and ignored)�super�__init__�warnings�warn� __class__�__name__r r )�selfr r �r � �D/opt/saltstack/salt/lib/python3.10/site-packages/zmq/auth/asyncio.pyr s
z AsyncioAuthenticator.__init__�returnc � sL � | j d u r d S | j �� I d H }| jt|�v r%| j�� I d H }| �|� q)N)r �pollr
�dictZrecv_multipartZhandle_zap_message)r �events�msgr r r Z __handle_zap! s �
�z!AsyncioAuthenticator.__handle_zapc s8 t � �� t� | _| j�| jtj� t� | �
� �| _ dS )zStart ZAP authenticationN) r
�startr r �registerr
�zmq�POLLIN�asyncioZ
ensure_future�!_AsyncioAuthenticator__handle_zapr �r r r r r * s
zAsyncioAuthenticator.startc s8 | j r| j �� | jr| j�| j� d| _t� �� dS )zStop ZAP authenticationN)r �cancelr �
unregisterr
r
�stopr" r r r r% 1 s
zAsyncioAuthenticator.stop)NN)r N)
r �
__module__� __qualname__�__doc__r r �__annotations__r r r! r r% �
__classcell__r r r r r s
r )
r( r r �typingr r r Z zmq.asyncior �baser r �__all__r r r r �<module> s
(