&eddlmZmZmZmZmZddlmZddlm Z ddl m Z ee Z GddZde defd Zd e d e dee fd Zd S))AnyDictListOptionalTuple) get_logger)Delta) ForwardMsgcpeZdZdZdZdeeeffdZde fdZ de ddfdZ d d Z dee fd ZdS) ForwardMsgQueuea:Accumulates a session's outgoing ForwardMsgs. Each AppSession adds messages to its queue, and the Server periodically flushes all session queues and delivers their messages to the appropriate clients. ForwardMsgQueue is not thread-safe - a queue should only be used from a single thread. c:g|_t|_dS)N_queuedict_delta_index_mapselfs Clib/python3.11/site-packages/streamlit/runtime/forward_msg_queue.py__init__zForwardMsgQueue.__init__#s(* =AFFreturncddlmfd|jDt|jdS)Nr) MessageToDictc&g|] }|Sr).0mrs r z-ForwardMsgQueue.get_debug..0s#<<<1mmA&&<<    %$%%%% : $    8'''' tJ'rr r(rc||dsdS|jd}|dko|dkS)zHTrue if the ForwardMsg is potentially composable with other ForwardMsgs.r0Ftypeadd_rowsarrow_add_rows)HasFieldr0 WhichOneof)r( delta_types rr*r*asH << u %%f--J  # F 6F(FFr old_delta new_deltac|d}|dkrdS|d}|dkr|S|dkr|SdS)aJCombines new_delta onto old_delta if possible. If the combination takes place, the function returns a new Delta that should replace old_delta in the queue. If the new_delta is incompatible with old_delta, the function returns None. In this case, the new_delta should just be appended to the queue as normal. rC add_blockN new_element)rG)rIrJold_delta_typenew_delta_types rr/r/nsc))&11N$$t))&11N&&$$ 4rN)typingrrrrrstreamlit.loggerrstreamlit.proto.Delta_pb2r streamlit.proto.ForwardMsg_pb2r r<LOGGERr rAr*r/rrrrUs43333333333333''''''++++++555555 H  FFFFFFFFR G Gt G G G G!U!u!%!!!!!!r