U /e@sdZddlmZddlZeeZddlmZm Z ddl m Z m Z ddl mZmZddlmZerzdd lmZd d lmZd ZGd dde ZGdddedZGdddeZGdddeZGdddeZGdddeZGdddeZdS)z\ Provide a set of objects to represent different stages of a connection to a Bokeh server. ) annotationsN)ABCMetaabstractmethod)Enumauto) TYPE_CHECKINGAny)ID)Message)ClientConnection)CONNECTED_BEFORE_ACKCONNECTED_AFTER_ACK DISCONNECTED ErrorReasonNOT_YET_CONNECTEDWAITING_FOR_REPLYc@seZdZeZeZeZdS)rN)__name__ __module__ __qualname__rNO_ERRORZ HTTP_ERROR NETWORK_ERRORrr7/tmp/pip-unpacked-wheel-f5fndrjf/bokeh/client/states.pyr9src@s eZdZedddddZdS)Stater None connectionreturncsdSNrselfrrrrrun@sz State.runN)rrrrr#rrrrr>sr) metaclassc@s eZdZdZdddddZdS)rz5 The ``ClientConnection`` is not yet connected. r rrcs|IdHdSr )Z_connect_asyncr!rrrr#IszNOT_YET_CONNECTED.runNrrr__doc__r#rrrrrDsrc@s eZdZdZdddddZdS)rzi The ``ClientConnection`` connected to a Bokeh server, but has not yet received an ACK from it. r rrcs|IdHdSr )Z _wait_for_ackr!rrrr#RszCONNECTED_BEFORE_ACK.runNr%rrrrrLsrc@s eZdZdZdddddZdS)rza The ``ClientConnection`` connected to a Bokeh server, and has received an ACK from it. r rrcs|IdHdSr )Z_handle_messagesr!rrrr#[szCONNECTED_AFTER_ACK.runNr%rrrrrUsrc@steZdZdZejddfdddddd d Zedd d d Zedd ddZ edd ddZ dddddZ dS)rz] The ``ClientConnection`` was connected to a Bokeh server, but is now disconnected. Nrz int | Nonestrr)reason error_code error_detailrcCs||_||_||_dS)z Constructs a DISCONNECT-State with given reason (``ErrorReason`` enum), error id and additional information provided as string. N) _error_code _error_detail _error_reason)r"r)r*r+rrr__init__dszDISCONNECTED.__init__rcCs|jS)zD The reason for the error encoded as an enumeration value. )r.r"rrr error_reasonnszDISCONNECTED.error_reasoncCs|jS)z8 Holds the error code, if any. None otherwise. )r,r1rrrr*uszDISCONNECTED.error_codecCs|jS)zC Holds the error message, if any. Empty string otherwise. )r-r1rrrr+|szDISCONNECTED.error_detailr rcsdSr rr!rrrr#szDISCONNECTED.run) rrrr&rrr/propertyr2r*r+r#rrrrr^s rc@s^eZdZUdZded<dddddZedd d d Zedd d d ZdddddZ dS)rz The ``ClientConnection`` has sent a message to the Bokeh Server which should generate a paired reply, and is waiting for the reply. zMessage[Any] | None_replyr r)reqidrcCs||_d|_dSr )_reqidr4)r"r5rrrr/szWAITING_FOR_REPLY.__init__r0cCs|jS)z? The reply from the server. (``None`` until the reply arrives) )r4r1rrrreplyszWAITING_FOR_REPLY.replycCs|jS)z, The request ID of the originating message. )r6r1rrrr5szWAITING_FOR_REPLY.reqidr rcst|IdH}|dkr.|ttjIdHnBd|jkrb|jd|jkrb||_|t IdHn| IdHdS)Nr5) _pop_messageZ_transition_to_disconnectedrrrheaderr5r4Z _transitionr_next)r"rmessagerrrr#szWAITING_FOR_REPLY.runN) rrrr&__annotations__r/r3r7r5r#rrrrrs r)r& __future__rlogging getLoggerrlogabcrrenumrrtypingrrZ core.typesr Zprotocol.messager rr __all__rrrrrrrrrrrs$       (