← Back
Editing: ioloop.cpython-311.pyc
� mc�c � �h � d Z ddlmZmZ ddlmZ ddlZddlmZ ddl m Z G d� d e � � Z d gZ dS ) zNZAP Authenticator integrated with the tornado IOLoop. .. versionadded:: 14.1 � )�Any�Optional)�ioloopN)� zmqstream� )� Authenticatorc � � � e Zd ZU dZej ed< ej ed< dde d de d e de ej f� fd � Z d� fd � Z � fd �Z� xZS )�IOLoopAuthenticatorz0ZAP authentication for use in the tornado IOLoop� zap_stream�io_loopN�utf-8�contextz zmq.Context�encoding�logc � �� t � � � |||� � d | _ |p t j � � � | _ d S )N)�super�__init__r r �IOLoop�currentr )�selfr r r r � __class__s ��1/usr/lib/python3/dist-packages/zmq/auth/ioloop.pyr z IOLoopAuthenticator.__init__ sF �� � ������(�C�0�0�0� ��� �9�&�-�"7�"7�"9�"9�� � � � �returnc �� �� t � � � � � t j | j | j � � | _ | j � | j � � dS )zStart ZAP authenticationN) r �startr � ZMQStream� zap_socketr r �on_recv�handle_zap_message�r r s �r r zIOLoopAuthenticator.start# sK �� � ��� � ����#�-�d�o�t�|�L�L��� �� � �� 7�8�8�8�8�8r c � �� | j r | j � � � d| _ t � � � � � dS )zStop ZAP authenticationN)r �closer �stopr! s �r r$ zIOLoopAuthenticator.stop) s= �� � �?� #� �O� !� !� #� #� #� "�D�O� ��� � �����r )Nr NN)r N)�__name__� __module__� __qualname__�__doc__r r �__annotations__r r r �strr r r r$ � __classcell__)r s @r r r s� �� � � � � � �:�:��#�#�#�#� �]���� ,0� ��+/� :� :��-�(� :� � :� � :� �&�-�(� :� :� :� :� :� :�9� 9� 9� 9� 9� 9� � � � � � � � � r r ) r( �typingr r �tornador �zmq� zmq.eventloopr �baser r �__all__� r r �<module>r3 s� ��� � !� � � � � � � � � � � � � � � � � � #� #� #� #� #� #� � � � � � � � � � � �-� � � �> !� !���r
Save File
Cancel