o
    i[                     @   s8   d dl Z d dlZd dlZd dlmZ G dd deZdS )    N)BaseZMQTestCasec                       s,   e Zd Z fddZdd Zdd Z  ZS )TestDraftSocketsc                    s   t jstd t   d S )Nzdraft api unavailable)zmq	DRAFT_APIpytestskipsupersetUp)self	__class__ O/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/tests/test_draft.pyr	      s   
zTestDraftSockets.setUpc                 C   sd   |  tjtj\}}|d | j|dd}|jd usJ |jd|jd | |}|dks0J d S )Ns   requestF)copys   reply)
routing_id)create_bound_pairr   CLIENTSERVERsendrecvr   )r
   clientservermsgreplyr   r   r   test_client_server   s   

z#TestDraftSockets.test_client_serverc           
   	   C   s   |  tjtj\}}d|_d}|| d}t }t }tdD ]4}t|	d}|
| |j||d z| }	W n tjyJ   td Y q w |
|	 |d7 }q t||d	ks`J d S )
N   mygroupr   
   ascii)groupg?      )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   recvdr   r   r   test_radio_dish   s&   



z TestDraftSockets.test_radio_dish)__name__
__module____qualname__r	   r   r7   __classcell__r   r   r   r   r      s    	r   )r,   r   r   	zmq.testsr   r   r   r   r   r   <module>   s
   