
    ytf                     \    d dl Z 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yy)    N)BaseZMQTestCase	GreenTesthave_geventc                       e Zd Z	 d Zd Zy)
TestPubSubc                 $   | j                  t        j                  t        j                        \  }}|j	                  t        j
                  d       t        j                  d       d}|j                  |       |j                         }||k(  sJ y )N    皙?   message)
create_bound_pairzmqPUBSUB
setsockopt	SUBSCRIBEtimesleepsendrecvselfs1s2msg1msg2s        _/var/www/html/software/conda/envs/higlass/lib/python3.12/site-packages/zmq/tests/test_pubsub.py
test_basiczTestPubSub.test_basic   sd    ''9B
cmmS)

3
wwyt||r	   c                    | j                  t        j                  t        j                        \  }}|j	                  t        j
                  d       t        j                  d       d}|j                  |       | j                  t        j                  |j                  t        j                         d}|j                  |       |j                         }||k(  sJ y )N   xr
   r   s   xmessage)r   r   r   r   r   r   r   r   r   assertRaisesErrnoEAGAINr   NOBLOCKr   s        r   
test_topiczTestPubSub.test_topic   s    ''9B
cmmT*

3
szz277CKK@
wwyt||r	   N)__name__
__module____qualname__r   r#    r	   r   r   r      s    
r	   r   c                       e Zd Zy)TestPubSubGreenN)r$   r%   r&   r'   r	   r   r)   r)   '   s    r	   r)   )r   r   	zmq.testsr   r   r   r   r)   r'   r	   r   <module>r+      s7   
  
 = = 4 )Z  r	   