
    Mhf                     N    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dS )zI Defines a dummy socket implementing (part of) the zmq.Socket interface.     )QueueN)	HasTraitsInstanceIntc                   ~    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dS )DummySocketz?A dummy socket implementing (part of) the zmq.Socket interface. r   c                 (    t          j                    S )N)zmqContext)selfs    Z/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/ipykernel/inprocess/socket.py_context_defaultzDummySocket._context_default   s    {}}    TFc                 4    | j                                         S )zRecv a multipart message.)queue
get_nowait)r   flagscopytracks       r   recv_multipartzDummySocket.recv_multipart   s    z$$&&&r   c                     t          t          t          j        |                    }| j                            |           | xj        dz  c_        dS )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"   sK    S[)4455	
i(((Qr         ?c                     dS )zno-op to comply with stream APINr	   )r   timeouts     r   flushzDummySocket.flush(   s      r   N)r   TF)r!   )__name__
__module____qualname____doc__r   r   r   r   r   r   r   contextr   r   r    r$   r	   r   r   r   r      s        IIHUBE3q66Lhs{##G  ' ' ' '   . . . . . .r   r   )	r(   r   r   r   	traitletsr   r   r   r   r	   r   r   <module>r+      sz    O O
       



 . . . . . . . . . .. . . . .) . . . . .r   