B @\@sfdZddlmZmZmZmZddlZeeZ ddl Z ddl m Z ddl mZdZGdd d eZdS) zn Assemble WebSocket wire message fragments into complete Bokeh Server message objects that can be processed. )absolute_importdivisionprint_functionunicode_literalsN)gen)ValidationError)Receiverc@sfeZdZdZddZejddZddZdd Z d d Z d d Z ddZ ddZ ddZddZdS)r a Receive wire message fragments and assemble complete Bokeh server message objects. On ``MessageError`` or ``ValidationError``, the receiver will reset its state and attempt to consume a new message. The *fragment* received can be either bytes or unicode, depending on the transport's semantics (WebSocket allows both). .. code-block:: python [ # these are required b'{header}', # serialized header dict b'{metadata}', # serialized metadata dict b'{content}, # serialized content dict # these are optional, and come in pairs; header contains num_buffers b'{buf_header}', # serialized buffer header dict b'array' # raw buffer payload data ... ] The ``header`` fragment will have the form: .. code-block:: python header = { # these are required 'msgid' : # a unique id for the message 'msgtype' : # a message type, e.g. 'ACK', 'PATCH-DOC', etc # these are optional 'num_buffers' : # the number of additional buffers, if any } The ``metadata`` fragment may contain any arbitrary information. It is not processed by Bokeh for any purpose, but may be useful for external monitoring or instrumentation tools. The ``content`` fragment is defined by the specific message type. cCs||_|j|_d|_d|_dS)z Configure a Receiver with a specific Bokeh protocol version. Args: protocol (Protocol) : A Bokeh protocol object to use to assemble collected message fragments. N) _protocol_HEADER_current_consumer_message _buf_header)selfZprotocolr6lib/python3.7/site-packages/bokeh/protocol/receiver.py__init__^szReceiver.__init__cCs||t|jdS)a  Consume individual protocol message fragments. Args: fragment (``JSON``) : A message fragment to assemble. When a complete message is assembled, the receiver state will reset to begin consuming a new message. N)r rZReturnr )rfragmentrrrconsumeks zReceiver.consumecCs*||d|_d|_|g|_|j|_dS)N) _assume_textr _partial _fragments _METADATAr )rrrrrr ys  zReceiver._HEADERcCs"|||j||j|_dS)N)rrappend_CONTENTr )rrrrrrs  zReceiver._METADATAcCsH|||j||jdd\}}}|j||||_|dS)N)rrrr Zassembler_check_complete)rrZ header_jsonZ metadata_jsonZ content_jsonrrrrs   zReceiver._CONTENTcCs||||_|j|_dS)N)rr_BUFFER_PAYLOADr )rrrrr_BUFFER_HEADERs zReceiver._BUFFER_HEADERcCs&|||j|j||dS)N)_assume_binaryrZassemble_bufferrr)rrrrrrs zReceiver._BUFFER_PAYLOADcCs&|jjr|j|_|j|_n|j|_dS)N)rZcompleter r r r)rrrrrs zReceiver._check_completecCs t|tjstd|jjdS)Nz:expected text fragment but received binary fragment for %s) isinstancesixZ text_typerr __name__)rrrrrrs zReceiver._assume_textcCs t|tjstd|jjdS)Nz:expected binary fragment but received text fragment for %s)r r!Z binary_typerr r")rrrrrrs zReceiver._assume_binaryN)r" __module__ __qualname____doc__rr coroutinerr rrrrrrrrrrrr 1s+  r )r%Z __future__rrrrZloggingZ getLoggerr"logr!Ztornador exceptionsr__all__objectr rrrr s