B \J @sRdZyddlmZmZWn$ek r<ddlmZmZYnXGdddeZdS)zLBlocking channels Useful for test suites and blocking terminal interfaces. )QueueEmptycs|eZdZdZdZdZdZdZgZdfdd Z ddZ dd d Z d d Z d dZ ddZeZddZddZddZZS)ZMQSocketChannelz%A ZMQ socket in a simple blocking APINFcstt|||_||_dS)aCreate a channel. Parameters ---------- socket : :class:`zmq.Socket` The ZMQ socket to use. session : :class:`session.Session` The session to use. loop Unused here, for other implementations N)superr__init__socketsession)selfrrZloop) __class__?lib/python3.7/site-packages/jupyter_client/blocking/channels.pyrs zZMQSocketChannel.__init__cKs*|jjf|}|j|\}}|j|S)N)rZrecv_multipartrZfeed_identitiesZ deserialize)r kwargsmsgZidentZsmsgr r r _recv(szZMQSocketChannel._recvTcCsD|r"|dk r|d9}|j|}n|jjdd}|r<|StdS)z/ Gets a message if there is one that is ready. Nir)timeout)rpollrr)r blockrZreadyr r r get_msg-szZMQSocketChannel.get_msgcCs<g}x2y||jddWqtk r2PYqXqW|S)z, Get all messages that are currently ready. F)r)appendrr)r Zmsgsr r r get_msgs;s zZMQSocketChannel.get_msgscCst|jjddS)z, Is there a message that has been received? r)r)boolrr)r r r r msg_readyEszZMQSocketChannel.msg_readycCs<|jdk r8y|jjddWntk r0YnXd|_dS)Nr)Zlinger)rclose Exception)r r r r rIs  zZMQSocketChannel.closecCs |jdk S)N)r)r r r r is_aliveRszZMQSocketChannel.is_alivecCs|j|j|dS)z1Pass a message to the ZMQ socket to send N)rsendr)r rr r r rUszZMQSocketChannel.sendcCsdS)Nr )r r r r startZszZMQSocketChannel.start)N)TN)__name__ __module__ __qualname____doc__rrstreamZ_exitingZ proxy_methodsrrrrrrstoprrr __classcell__r r )r r rs   rN)r Zqueuerr ImportErrorobjectrr r r r s