← Back
Editing: asyncio.cpython-311.pyc
� mc�cc � �l � d Z ddlZddlZddlmZmZ ddlZddlmZ ddl m Z G d� de � � Z dgZ dS ) zOZAP Authenticator integrated with the asyncio IO loop. .. versionadded:: 15.2 � N)�Any�Optional)�Poller� )� Authenticatorc � � � e Zd ZU dZee ed< eed< ded< dded d ef� fd � Zdd �Z d� fd � Z d� fd� Z � xZ S )�AsyncioAuthenticatorz1ZAP authentication for use in the asyncio IO loop� _AsyncioAuthenticator__poller�_AsyncioAuthenticator__taskzzmq.asyncio.Socket� zap_socketN�contextz zmq.Context�loopc � �� t � � � |� � |�!t j | j j � d�� � d | _ d | _ d S )Nz (loop) is deprecated and ignored)�super�__init__�warnings�warn� __class__�__name__r r )�selfr r r s ��2/usr/lib/python3/dist-packages/zmq/auth/asyncio.pyr z AsyncioAuthenticator.__init__ sQ �� � ������!�!�!� � � �M�T�^� 4�V�V�V� W� W� W� �� ��� � � � �returnc � � K � | j �r| j � � � � d {V ��}| j t |� � v r4| j � � � � d {V ��}| � |� � | j �pd S d S )N)r �pollr �dict�recv_multipart�handle_zap_message)r �events�msgs r � __handle_zapz!AsyncioAuthenticator.__handle_zap! s� � � � ��m�'� �=�-�-�/�/�/�/�/�/�/�/�F���$�v�,�,�.�.� �O� :� :� <� <�<�<�<�<�<�<���'�'��,�,�,� �m�'�'�'�'�'r c � �� t � � � � � t � � | _ | j � | j t j � � t j | � � � � � | _ dS )zStart ZAP authenticationN) r �startr r �registerr �zmq�POLLIN�asyncio� ensure_future�!_AsyncioAuthenticator__handle_zapr �r r s �r r# zAsyncioAuthenticator.start( s] �� � ��� � ���� ���� � � � � �t��� �;�;�;� �+�D�,=�,=�,?�,?�@�@�� � � r c �� �� | j r| j � � � | j r&| j � | j � � d| _ t � � � � � dS )zStop ZAP authenticationN)r �cancelr � unregisterr r �stopr* s �r r. zAsyncioAuthenticator.stop/ s_ �� � �;� !� �K� � � � � � �=� !� �M� $� $�T�_� 5� 5� 5� �D�M� ��� � �����r )NN)r N) r � __module__� __qualname__�__doc__r r �__annotations__r r r) r# r. � __classcell__)r s @r r r s� �� � � � � � �;�;��v� � � � � �K�K�K�$�$�$�$�� �� � 7� �c� � � � � � �-� -� -� -�A� A� A� A� A� A�� � � � � � � � � r r ) r1 r' r �typingr r r% � zmq.asyncior �baser r �__all__� r r �<module>r9 s� ��� � ���� ���� � � � � � � � � � � � � � � � � � � � � � � � �#� #� #� #� #�=� #� #� #�L "� "���r
Save File
Cancel