
    Zd[                     F    d dl Z d dlZd dlZd dlmZ  G d de          ZdS )    N)BaseZMQTestCasec                   *     e Zd Z fdZd Zd Z xZS )TestDraftSocketsc                     t           j        st          j        d           t	                                                       d S )Nzdraft api unavailable)zmq	DRAFT_APIpytestskipsupersetUp)self	__class__s    4lib/python3.11/site-packages/zmq/tests/test_draft.pyr   zTestDraftSockets.setUp   s3    } 	1K/000    c                 <   |                      t          j        t          j                  \  }}|                    d           |                     |d          }|j        J |                    d|j                   |                     |          }|dk    sJ d S )Ns   requestF)copys   reply)
routing_id)create_bound_pairr   CLIENTSERVERsendrecvr   )r   clientservermsgreplys        r   test_client_serverz#TestDraftSockets.test_client_server   s    //
CJGGJiiUi++~)))H888		&!!      r   c                    |                      t          j        t          j                  \  }}d|_        d}|                    |           d}t                      }t                      }t          d          D ]}t          |          	                    d          }|
                    |           |                    ||           	 |                                }	|
                    |	           |dz  }# t          j        $ r t          j        d           Y w xY wt!          |                    |                    d	k    sJ d S )
N   mygroupr   
   ascii)group   g?   )r   r   DISHRADIOrcvtimeojoinsetrangestrencodeaddr   r   Againtimesleeplenintersection)
r   dishradior#   received_countreceivedsentir   recvds
             r   test_radio_dishz TestDraftSockets.test_radio_dish   s6   ,,SXsyAAe		%55uur 
	$ 
	$Aa&&--((CHHSMMMJJs%J((($		 U###!#	 9      
3  8((..//1444444s   
C99#DD)__name__
__module____qualname__r   r   r;   __classcell__)r   s   @r   r   r      sV            
! ! !5 5 5 5 5 5 5r   r   )r0   r	   r   	zmq.testsr   r    r   r   <module>rB      sh      



 % % % % % %#5 #5 #5 #5 #5 #5 #5 #5 #5 #5r   