U
    lufÐ  ã                   @   sJ   d dl Z d dlmZmZmZ dZG dd„ deƒZerFG dd„ deeƒZdS )é    N)ÚBaseZMQTestCaseÚ	GreenTestÚhave_geventó    c                   @   s,   e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd	S )
ÚTestPairc                 C   s6   |   tjtj¡\}}d}|  |||¡}||ks2t‚d S )Ns   message1)Úcreate_bound_pairÚzmqÚPAIRZ	ping_pongÚAssertionError)ÚselfÚs1Ús2Zmsg1Zmsg2© r   ú7/tmp/pip-unpacked-wheel-h6ekxre8/zmq/tests/test_pair.pyÚ
test_basic   s    zTestPair.test_basicc                 C   s¤   |   tjtj¡\}}tdƒD ]}|t }| |¡ qtdƒD ]}|t }| |¡ q<tdƒD ]}| ¡ }||t ks\t‚q\tdƒD ]}| ¡ }||t ks‚t‚q‚d S )Né
   )r   r   r	   ÚrangeÚxÚsendÚrecvr
   )r   r   r   ÚiÚmsgr   r   r   Útest_multiple   s    zTestPair.test_multiplec                 C   s:   |   tjtj¡\}}tdttdƒƒd}|  |||¡ d S ©Nr   )ÚaÚb)r   r   r	   ÚdictÚlistr   Zping_pong_json©r   r   r   Úor   r   r   Ú	test_json&   s    zTestPair.test_jsonc                 C   s6   |   tjtj¡\}}tdtdƒd}|  |||¡ d S r   )r   r   r	   r   r   Zping_pong_pyobjr   r   r   r   Ú
test_pyobj+   s    zTestPair.test_pyobjN)Ú__name__Ú
__module__Ú__qualname__r   r   r    r!   r   r   r   r   r      s   r   c                   @   s   e Zd ZdS )ÚTestReqRepGreenN)r"   r#   r$   r   r   r   r   r%   3   s   r%   )r   Z	zmq.testsr   r   r   r   r   r%   r   r   r   r   Ú<module>   s
   &