
    Xhf                     F    d Z ddlmZ ddlZddlmZmZmZ  G d de      Zy)zI Defines a dummy socket implementing (part of) the zmq.Socket interface.     )QueueN)	HasTraitsInstanceIntc                   t    e Zd ZdZ eed      Z ed      Z ee	j                        Zd Zd	dZd	dZd
dZy)DummySocketz?A dummy socket implementing (part of) the zmq.Socket interface. r   c                 *    t        j                         S )N)zmqContext)selfs    N/var/www/html/myenv/lib/python3.12/site-packages/ipykernel/inprocess/socket.py_context_defaultzDummySocket._context_default   s    {{}    c                 6    | j                   j                         S )zRecv a multipart message.)queue
get_nowait)r   flagscopytracks       r   recv_multipartzDummySocket.recv_multipart   s    zz$$&&r   c                     t        t        t        j                  |            }| j                  j                  |       | xj                  dz  c_        y)zSend a multipart message.   N)listmapr   Messager   
put_nowaitmessage_sent)r   	msg_partsr   r   r   s        r   send_multipartzDummySocket.send_multipart"   s:    S[[)45	

i(Qr   c                      y)zno-op to comply with stream APINr	   )r   timeouts     r   flushzDummySocket.flush(   s    r   N)r   TF)g      ?)__name__
__module____qualname____doc__r   r   r   r   r   r   r   contextr   r   r    r#   r	   r   r   r   r      s<    IUBEq6Ls{{#G'.r   r   )	r'   r   r   r   	traitletsr   r   r   r   r	   r   r   <module>r*      s"    O
  
 . ..) .r   