
    Zd                     d    d dl Z d dlmZmZmZ  G d de          Zer G d dee          ZdS dS )    N)BaseZMQTestCase	GreenTesthave_geventc                   2    e Zd Zd Zd Zd Zd Zd Zd ZdS )
TestReqRepc                     |                      t          j        t          j                  \  }}d}|                     |||          }||k    sJ d S )Ns	   message 1)create_bound_pairzmqREQREP	ping_pong)selfs1s2msg1msg2s        5lib/python3.11/site-packages/zmq/tests/test_reqrep.py
test_basiczTestReqRep.test_basic
   sJ    ''99B~~b"d++t||||||    c                     |                      t          j        t          j                  \  }}t	          d          D ]&}|dz  }|                     |||          }||k    sJ 'd S )N
       r	   r
   r   r   ranger   )r   r   r   ir   r   s         r   test_multiplezTestReqRep.test_multiple   sk    ''99Br 	  	 At8D>>"b$//D4<<<<<	  	 r   c                 x   |                      t          j        t          j                  \  }}t          j                    dk    rTdD ]Q}|                     t          j        |j        |           |                     t          j        |j        d|           Rd}| 	                    |||          }||k    sJ d S )Nz2.1.8)TF)copys   asdf)
r	   r
   r   r   zmq_versionassertRaisesErrnoEFSMrecvsendr   )r   r   r   r   r   r   s         r   test_bad_send_recvzTestReqRep.test_bad_send_recv   s    ''99B?''% N N&&sxt&DDD&&sx'&MMMM ~~b"d++t||||||r   c                     |                      t          j        t          j                  \  }}t	          dt          t          d                              }|                     |||           d S Nr   )ab)r	   r
   r   r   dictlistr   ping_pong_jsonr   r   r   os       r   	test_jsonzTestReqRep.test_json'   s[    ''99B2eBii)))BA&&&&&r   c                     |                      t          j        t          j                  \  }}t	          dt          d                    }|                     |||           d S r&   )r	   r
   r   r   r)   r   ping_pong_pyobjr,   s       r   
test_pyobjzTestReqRep.test_pyobj,   sU    ''99B2r###RQ'''''r   c                     |                      t          j        t          j                  \  }}ddz  }t	          d          D ]!}|                     |||          }||k    sJ "d S )Ni'     Xr   r   )r   r   r   r   r   r   s         r   test_large_msgzTestReqRep.test_large_msg1   sk    ''99Bt|r 	  	 A>>"b$//D4<<<<<	  	 r   N)	__name__
__module____qualname__r   r   r$   r.   r1   r4    r   r   r   r   	   sn                 ' ' '
( ( (
         r   r   c                       e Zd ZdS )TestReqRepGreenN)r5   r6   r7   r8   r   r   r:   r:   <   s        r   r:   )r
   	zmq.testsr   r   r   r   r:   r8   r   r   <module>r<      s   
 


 = = = = = = = = = =.  .  .  .  .  .  .  . b      )Z      r   