U lu fäã@sFddlZddlmZmZmZGdd„deƒZerBGdd„deeƒZdS)éN)ÚBaseZMQTestCaseÚ GreenTestÚ have_geventc@s<eZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd S)Ú TestReqRepcCs6| tjtj¡\}}d}| |||¡}||ks2t‚dS)Ns message 1)Úcreate_bound_pairÚzmqÚREQÚREPÚ ping_pongÚAssertionError)ÚselfÚs1Ús2Úmsg1Úmsg2©rú9/tmp/pip-unpacked-wheel-h6ekxre8/zmq/tests/test_reqrep.pyÚ test_basic szTestReqRep.test_basiccCsH| tjtj¡\}}tdƒD]&}|d}| |||¡}||kst‚qdS)Né ó ©rrrr Úranger r )r r rÚirrrrrÚ test_multiples  zTestReqRep.test_multiplecCsv| tjtj¡\}}t ¡dkrTdD].}|jtj|j|d|jtj|jd|dq$d}|  |||¡}||ksrt ‚dS)Nz2.1.8)TF)Úcopysasdf) rrrr Z zmq_versionZassertRaisesErrnoZEFSMÚrecvÚsendr r )r r rrrrrrrÚtest_bad_send_recvs zTestReqRep.test_bad_send_recvcCs:| tjtj¡\}}tdttdƒƒd}| |||¡dS©Nr)ÚaÚb)rrrr ÚdictÚlistrZping_pong_json©r r rÚorrrÚ test_json'szTestReqRep.test_jsoncCs6| tjtj¡\}}tdtdƒd}| |||¡dSr)rrrr r!rZping_pong_pyobjr#rrrÚ test_pyobj,szTestReqRep.test_pyobjcCsH| tjtj¡\}}dd}tdƒD]}| |||¡}||ks$t‚q$dS)Ni'óXrr)r r rrrrrrrÚtest_large_msg1s  zTestReqRep.test_large_msgN) Ú__name__Ú __module__Ú __qualname__rrrr%r&r(rrrrr s rc@s eZdZdS)ÚTestReqRepGreenN)r)r*r+rrrrr,<sr,)rZ zmq.testsrrrrr,rrrrÚs1