o
    š©Zhf  ã                   @   s@   d Z ddlmZ ddlZddlmZmZmZ G dd„ deƒZdS )zI Defines a dummy socket implementing (part of) the zmq.Socket interface. é    )ÚQueueN)Ú	HasTraitsÚInstanceÚIntc                   @   sR   e Zd ZdZeedƒZedƒZee	j
ƒZdd„ Zddd	„Zdd
d„Zddd„ZdS )ÚDummySocketz?A dummy socket implementing (part of) the zmq.Socket interface.© r   c                 C   s   t  ¡ S )N)ÚzmqÚContext)Úselfr   r   úQ/var/www/html/lang_env/lib/python3.10/site-packages/ipykernel/inprocess/socket.pyÚ_context_default   s   zDummySocket._context_defaultTFc                 C   s
   | j  ¡ S )zRecv a multipart message.)ÚqueueÚ
get_nowait)r
   ÚflagsÚcopyÚtrackr   r   r   Úrecv_multipart   s   
zDummySocket.recv_multipartc                 C   s.   t ttj|ƒƒ}| j |¡ |  jd7  _dS )zSend a multipart message.é   N)ÚlistÚmapr   ÚMessager   Ú
put_nowaitÚmessage_sent)r
   Z	msg_partsr   r   r   r   r   r   Úsend_multipart"   s   zDummySocket.send_multipartç      ð?c                 C   s   dS )zno-op to comply with stream APINr   )r
   Útimeoutr   r   r   Úflush(   s    zDummySocket.flushN)r   TF)r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   r   r   r	   Úcontextr   r   r   r   r   r   r   r   r      s    



r   )	r    r   r   r   Z	traitletsr   r   r   r   r   r   r   r   Ú<module>   s
    