codekingpro/portable-devtools
114k
1�
2 ��j/ � 3 � � S SK Jr S SKJrJr S SKJrJr S SKJ r S SK4J r S SK J
r
Jr S SKJr SrS
S jr " S5 S \\ \
\\ \\\ - \\ 4 5 rg )� )� annotations)�Iterator�Sequence)�Any�Generic)�Self)�MISSING)� BaseChannel�Value)�EmptyChannelError)�Topicc # �l # � U H( n[ U[ 5 ( a U S h v�N M$ Uv � M* g N7f�N)�6isinstance�list)�values�values �^D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/channels/topic.py�_flattenr s- � � ��� �e�T� "� "� � � ��K� � �s � 4�2�4c � ^ � \ rS rSrSrSrSSU 4S jjjrSS jr\SS j5 r \SS j5 r7SS jr SS jr SS8 jr
SS jrSS jrSS
jrSrU =r$ )r
� z�A configurable PubSub Topic.9 10Args:11 typ: The type of the value stored in the channel.12 accumulate: Whether to accumulate values across steps. If `False`, the channel will be emptied after each step.13)r �14accumulatec �^ >� [ TU ] U5 X l [ [ " 5 U l g r )�super�__init__r r r r )�self�typr � __class__s �r r �Topic.__init__$ s" �� �
���� �$���5�k�m�� � c �b � [ U[ 5 =( a UR U R :H $ r )r r
r )r r s r �__eq__� Topic.__eq__+ s# � ��%��'�O�E�,<�,<����,O�Or c �( � [ U R $ )z,The type of the value stored in the channel.)r r �r s r � ValueType�Topic.ValueType. s � � ����!�!r c �B � U R [ U R - $ )z/The type of the update received by the channel.)r r r% s r �15UpdateType�Topic.UpdateType3 s � � �x�x�$�t�x�x�.�(�(r c � � U R U R U R 5 nU R Ul U R R 5 Ul U$ )z Return a copy of the channel.)r r r �keyr �copy)r �emptys r r- �16Topic.copy8 s> � ����t�x�x�� � �9���H�H�� ��{�{�'�'�)�� �� r c � � U R $ r )r r% s r �17checkpoint�Topic.checkpoint? s � ��{�{�r c �� � U R U R U R 5 nU R Ul U[ La' [ U[ 5 ( a US Ul U$ Xl U$ )N� )r r r r, r r �tupler )r r1 r. s r �from_checkpoint�Topic.from_checkpointB sX � ����t�x�x�� � �9���H�H�� � �W� $��*�e�,�,� )�!�}�� � � � *� �� r c �� � SnU R ( d, [ U R 5 n[ [ " 5 U l [ [
U5 5 =n( a SnU R R U5 U$ )NFT)r �boolr r r r5 r �extend)r r �updated� flat_valuess r �update� Topic.updateM sZ � �������4�;�;�'�G� �u�+�-�D�K� ��� 0�1� 1�;� 1��G� �K�K� � �{� +��r c �Z � U R ( a [ U R 5 $ [ er )r r r r% s r �get� Topic.getW s � � �;�;��� � �$� $�#� #r c �, � [ U R 5 $ r )r9 r r% s r � is_available�Topic.is_available] s � ��D�K�K� � r )r r )F)r z type[Value]r r9 �return�None)r �objectrE r9 )rE r )rE r )rE � list[Value])r1 rH rE r )r � Sequence[Value | list[Value]]rE r9 )rE zSequence[Value])rE r9 )�__name__�18__module__� __qualname__�__firstlineno__�__doc__� __slots__r r" �propertyr& r) r- r1 r6 r= r@ rC �__static_attributes__�
__classcell__)r s @r r
r
sj �� �� )�I�$� $�P� �"� �"� �)� �)��� ��$� !� !r r
N)r rI rE zIterator[Value])�19__future__r �collections.abcr r �typingr r �typing_extensionsr �langgraph._internal._typingr �langgraph.channels.baser20 r �langgraph.errorsr �__all__r r r
� r r �<module>r\ sW �� "� .� � "� /� 6� .�21���G!� �E�N�������e��!4�d�5�k�A�B�G!r