o i@sNdZddlmZddlmZddlZddlmZddlm Z GdddZ dS) zBPair of ZMQ inproc sockets used for communication between threads.) annotations)AnyN)IOLoop) ZMQStreamc@sVeZdZUdZded<ded<dZded<dd d ZddZddddZdddZ dS) SocketPairzPair of ZMQ inproc sockets for one-direction communication between 2 threads. One of the threads is always the shell_channel_thread, the other may be the control thread, main thread or a subshell thread. .. versionadded:: 7 zzmq.Socket[Any] from_socket to_socketNzZMQStream | None to_streamcontextzmq.Context[Any]namestrcCsB|tj|_|tj|_||}|j||j|dS)z"Initialize the inproc socker pair.N)socketzmqPAIRrr_addressbindconnect)selfr r addressrP/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/ipykernel/socket_pair.py__init__s   zSocketPair.__init__cCs,|j|jdur|j|jdS)zClose the inproc socker pair.N)rcloser r)rrrrr!s   zSocketPair.closeFio_looprcopyboolcCs,|jdur t|j||_|jj||ddS)zBSet the callback used when a message is received on the to stream.N)r)r rron_recv)rron_recv_callbackrrrrr)s zSocketPair.on_recvreturncCs d|S)z4Return the address used for this inproc socket pair.zinproc://subshellr)rr rrrr0s zSocketPair._address)r r r r )F)rrrr)rr ) __name__ __module__ __qualname____doc____annotations__r rrrrrrrrr s    r) r# __future__rtypingrrtornado.iolooprzmq.eventloop.zmqstreamrrrrrrs