codekingpro/portable-devtools
114k
1�
2 ��je � � � S r SSKJr SSKrSSKJrJr SSKJr SSK r SSK3r4SSK J r \
\- \- r " S S5 r " S S55 rS
S jrSS jrg)zCAdapted from httpx_sse to split lines on 6,
,
7 per the SSE spec.� )� annotationsN)�
AsyncIterator�Iterator)�cast)�8StreamPartc �6 � \ rS rSrSrSS jrS S jrS9S jrSrg) �BytesLineDecoder� z�10Handles incrementally reading lines from text.11 12Has the same behaviour as the stdllib bytes splitlines,13but handling the input iteratively.14c �0 � [ 5 U l SU l g �NF)� bytearray�buffer� trailing_cr��selfs �WD:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph_sdk/sse.py�__init__�BytesLineDecoder.__init__ s � � �k�� �!&��� c � � SnU R ( a SU- nSU l UR S5 ( a SU l US S nU( d / $ US U; n[ [ [ UR 5 5 n[
U5 S:X a' U( d U R R US 5 / $ U R ( aT U R R US 5 [ [ [ U R /USS Q5 n[ 5 U l U( d) U R R UR 5 5 U$ )Ns 15
�
FT������ r ) r �endswithr �list� BytesLike�16splitlines�lenr �extendr
�pop)r �text�
NEWLINE_CHARS�trailing_newline�liness r �decode�BytesLineDecoder.decode s17 � � �
� � � ��4�<�D� $�D� � �=�=�� � � #�D� ����9�D�� �I� ��8�}�4���T�)�_�d�o�o�&7�8�� �u�:��?�#3� �K�K� � �u�Q�x� (��I� �;�;�
�K�K� � �u�Q�x� (���i� �4�;�;�*C��q�r��*C�D�E�#�+�D�K� �
�K�K� � �u�y�y�{� +�� r c � � U R ( d U R ( d / $ U R /n[ 5 U l SU l U$ r )r r r
)r r$ s r �flush�BytesLineDecoder.flushD s7 � ��{�{�4�#3�#3��I����
�� �k�� � ���� r )r r N��return�None)r! �bytesr+ �list[BytesLike])r+ r. ) �__name__�18__module__� __qualname__�__firstlineno__�__doc__r r% r( �__static_attributes__� r r r r s � ��'�%�Nr r c �< � \ rS rSrSS jr\SS j5 rS S jrSrg)19�20SSEDecoder�N c �L � SU l [ 5 U l SU l S U l g )N� )�_eventr
�_data�_last_event_id�_retryr s r r �SSEDecoder.__init__O s! � ��� � �[��21� ���"&�� r c �, � U R =( d S$ )z/Return the last event identifier that was seen.N)r= r s r �
last_event_id�SSEDecoder.last_event_idU s � � �"�"�*�d�*r c �f � U( d� U R ( d0 U R ( d U R ( d U R c g [ U R U R ( a [22 R " U R 5 OS U R S9nSU l [ 5 U l S U l U$ UR S5 ( a g UR S5 u p4nUR S5 ( a USS nUS:X a UR 5 U l g US:X a U R R U5 g US:X a S U; a g UR 5 U l g US23:X a9 [ R " [ [ 5 [# U5 U l S S S 5 g g ! , ( d f g = f) N)�event�data�idr: � :� r s events datas id� s retry)r; r< r= r> r �orjson�loadsrA r
�24startswith� partitionr% r �25contextlib�suppress� TypeError�26ValueError�int)r �line�sse� fieldname�_�values r r% �SSEDecoder.decode[ sj � � ��K�K� �27�28� �+�+��K�K�'�� ��k�k�15���V�\�\�$�*�*�-���%�%��C� �D�K�"��D�J� �D�K��J� �?�?�4� � �� "�n�n�T� 2�� �e� � � �D� !� !��!�"�I�E� �� � �,�,�.�D�K� � �'�
!� �J�J� � �e� $� � �%�
���~�� � ',�l�l�n��#� �
�(�
"��$�$�Y�29�;� !�%�j�� � <�30 �
�� <�;�31 �s �F"�"32F0)r< r; r= r> Nr* )r+ z33str | None)rS r- r+ zStreamPart | None) r/ r0 r1 r2 r �propertyrA r% r4 r5 r r r7 r7 N s � �'� �+� �+�340r r7 c �� # � [ 5 nU R 5 S h v�N nUR U5 H nU7v � M35 M( N#36 UR 5 H nU7v � M37 g 7f�N)r � aiter_bytesr% r( ��response�decoder�chunkrS s r �aiter_lines_rawra � sW � � � � �G� �+�+�-� �e��N�N�5�)�D��J� *��-� �
�
����38� �s% �A%�A�A�A� A%�A� A%c # � # � [ 5 nU R 5 H nUR U5 H nUv � M M! UR 5 H nUv � M g 7fr[ )r �39iter_bytesr% r( r] s r �iter_lines_rawrd � sO � � � � �G��$�$�&���N�N�5�)�D��J� *� '� �
�
����40� �s �AA )r^ �httpx.Responser+ zAsyncIterator[BytesLike])r^ re r+ zIterator[BytesLike])r3 �41__future__r rN �collections.abcr r �typingr �httpxrJ �langgraph_sdk.schemar r- r
�42memoryviewr r r7 ra rd r5 r r �<module>rl sL �� M� "� � 3� � �
� +� �I� �43� *� �:� :�z=� =�@�r