+
    Ui>)                    v   ^ RI Ht ^ RIt^ RIt^ RIHt ^ RIHtHtH	t	H
t
HtHtHtHt ^ RIHtHtHtHtHtHt ^ RIt^RIHt ]'       d   ^RIHtHt ^RIHt ]
! R	4      t ! R
 R]	],          4      t ! R R]	],          4      t  ! R R4      t! ! R R4      t"] ! R R]4      4       t#R R lt$RR/R R llt%R# )    )annotationsN)TracebackType)TYPE_CHECKINGAnyGenericTypeVarIteratorOptionalAsyncIteratorcast)SelfProtocol	TypeGuardoverride
get_originruntime_checkable)extract_type_var_from_base)ParallelAsyncParallel)FinalRequestOptions_Tc                      ] tR t^t$ RtR]R&   RtR]R&   R]R&   R	R/R
 R lltR R ltR R lt	R R lt
R R ltR R ltR R ltR R ltRtR# )StreamzJProvides the core interface to iterate over a synchronous stream response.httpx.ResponseresponseNOptional[FinalRequestOptions]_optionsSSEBytesDecoder_decoderoptionsc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )   cast_totype[_T]r   r   clientr   r    r   returnNone )formats   "R/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/parallel/_streaming.py__annotate__Stream.__annotate__   s>     + + + !	+
 + /+ 
+    c               	    W n         Wn        W0n        W@n        VP	                  4       V n        V P                  4       V n        R # Nr   _cast_to_clientr   _make_sse_decoderr   
__stream__	_iteratorselfr#   r   r%   r    s   &$$$$r*   __init__Stream.__init__   6     !002*r-   c                   V ^8  d   QhRR/# r"   r&   r   r(   )r)   s   "r*   r+   r,   ,   s     ) )" )r-   c                	6    V P                   P                  4       # r/   )r5   __next__r7   s   &r*   r>   Stream.__next__,   s    ~~&&((r-   c                   V ^8  d   QhRR/# r"   r&   zIterator[_T]r(   )r)   s   "r*   r+   r,   /   s      , r-   c              #  	<   "   V P                    F  pVx  K	  	  R # 5ir/   r5   r7   items   & r*   __iter__Stream.__iter__/   s     NNDJ #s   c                   V ^8  d   QhRR/# )r"   r&   Iterator[ServerSentEvent]r(   )r)   s   "r*   r+   r,   3   s     H H7 Hr-   c              #  	   "   V P                   P                  V P                  P                  4       4       R j  xL
  R #  L5ir/   )r   
iter_bytesr   r?   s   &r*   _iter_eventsStream._iter_events3   s*     ==++DMM,D,D,FGGGs   7AA Ac                   V ^8  d   QhRR/# rB   r(   )r)   s   "r*   r+   r,   6   s      L r-   c              #  	8  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V F  pV! VP                  4       WR 7      x  K  	  VP                  4        R#   TP                  4        i ; i5i)datar#   r   N)	r   r   r1   r   r2   _process_response_datarM   jsoncloser7   r#   r   process_dataiteratorsses   &     r*   r4   Stream.__stream__6   ss     sDMM*==||::$$&	"
GWW   NNHNNs   AB#B 3BBBc                   V ^8  d   QhRR/# r"   r&   r   r(   )r)   s   "r*   r+   r,   C   s      4 r-   c                	    V # r/   r(   r?   s   &r*   	__enter__Stream.__enter__C   s    r-   c               (    V ^8  d   QhRRRRRRRR/# 	r"   exc_typeztype[BaseException] | NoneexczBaseException | Noneexc_tbzTracebackType | Noner&   r'   r(   )r)   s   "r*   r+   r,   F   s2      , " %	
 
r-   c                	&    V P                  4        R # r/   rU   r7   rb   rc   rd   s   &&&&r*   __exit__Stream.__exit__F   s     	

r-   c                   V ^8  d   QhRR/# r"   r&   r'   r(   )r)   s   "r*   r+   r,   N   s      t r-   c                :    V P                   P                  4        R# zr
Close the response and release the connection.

Automatically called if the response body is read to completion.
N)r   rU   r?   s   &r*   rU   Stream.closeN   s     	r-   r1   r2   r   r5   r   r   )__name__
__module____qualname____firstlineno____doc____annotations__r   r8   r>   rG   rM   r4   r^   rh   rU   __static_attributes__r(   r-   r*   r   r      sT    T.2H+2+ 26+)H r-   r   c                      ] tR t^Wt$ RtR]R&   RtR]R&   R]R&   R	R/R
 R lltR R ltR R lt	R R lt
R R ltR R ltR R ltR R ltRtR# )AsyncStreamzLProvides the core interface to iterate over an asynchronous stream response.r   r   Nr   r   zSSEDecoder | SSEBytesDecoderr   r    c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r"   r#   r$   r   r   r%   r   r    r   r&   r'   r(   )r)   s   "r*   r+   AsyncStream.__annotate__^   s>     + + + !	+
 + /+ 
+r-   c               	    W n         Wn        W0n        W@n        VP	                  4       V n        V P                  4       V n        R # r/   r0   r6   s   &$$$$r*   r8   AsyncStream.__init__^   r:   r-   c                   V ^8  d   QhRR/# r<   r(   )r)   s   "r*   r+   rz   m   s     0 0 0r-   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir/   )r5   	__anext__r?   s   &r*   r   AsyncStream.__anext__m   s     ^^--////s   '%'c                   V ^8  d   QhRR/# r"   r&   zAsyncIterator[_T]r(   )r)   s   "r*   r+   rz   p   s      !2 r-   c               	N   "   V P                     R j  xL
  pV5x  K   LDR # 5ir/   rD   rE   s   & r*   	__aiter__AsyncStream.__aiter__p   s$     .. 	 	$J	.s   %" "	%"%c                   V ^8  d   QhRR/# )r"   r&   AsyncIterator[ServerSentEvent]r(   )r)   s   "r*   r+   rz   t   s      $B r-   c               	   "   V P                   P                  V P                  P                  4       4        R j  xL
  pV5x  K   LDR # 5ir/   )r   aiter_bytesr   )r7   rY   s   & r*   rM   AsyncStream._iter_eventst   s=     224==3L3L3NO 	 	#I	Os%   4AA	AA		AA		Ac                   V ^8  d   QhRR/# r   r(   )r)   s   "r*   r+   rz   x   s     $ $"3 $r-   c               	p  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V  R j  xL
  pV! VP                  4       WR7      5x  K'   L"D# TP                  4       G R j  xL 
  R #   TP                  4       G R j  xL 
  i ; i5i)NrQ   )	r   r   r1   r   r2   rS   rM   rT   acloserV   s   &     r*   r4   AsyncStream.__stream__x   s     sDMM*==||::$$&	$% X Xc"
GWWXX //###(//###sZ   AB6B A;A9A;B 9A;;B =B6BB6B3,B/-B33B6c                   V ^8  d   QhRR/# r\   r(   )r)   s   "r*   r+   rz      s      $ r-   c                	   "   V # 5ir/   r(   r?   s   &r*   
__aenter__AsyncStream.__aenter__   s
     s   c               (    V ^8  d   QhRRRRRRRR/# ra   r(   )r)   s   "r*   r+   rz      s2      , " %	
 
r-   c                	B   "   V P                  4       G R j  xL
  R #  L5ir/   rf   rg   s   &&&&r*   	__aexit__AsyncStream.__aexit__   s      jjls   c                   V ^8  d   QhRR/# rk   r(   )r)   s   "r*   r+   rz      s     % %T %r-   c                V   "   V P                   P                  4       G Rj  xL
  R#  L5irm   )r   r   r?   s   &r*   rU   AsyncStream.close   s      mm""$$$s   )')ro   )rp   rq   rr   rs   rt   ru   r   r8   r   r   rM   r4   r   r   rU   rv   r(   r-   r*   rx   rx   W   sS    V.2H+2**+ 26+0$% %r-   rx   c                      ] tR t^tRRRRRRRR/R R llt]R R	 l4       t]R
 R l4       t]R R l4       t]R R l4       t	R R lt
]R R l4       tRtR# )ServerSentEventeventNrR   idretryc          
     ,    V ^8  d   QhRRRRRRRRRR/# )	r"   r   
str | NonerR   r   r   
int | Noner&   r'   r(   )r)   s   "r*   r+   ServerSentEvent.__annotate__   s>        	
   
r-   c               	X    Vf   RpW0n         W n        T;'       g    R V n        W@n        R # )N )_id_data_event_retry)r7   r   rR   r   r   s   &$$$$r*   r8   ServerSentEvent.__init__   s*     <D
mmtr-   c                   V ^8  d   QhRR/# r"   r&   r   r(   )r)   s   "r*   r+   r            z r-   c                	    V P                   # r/   )r   r?   s   &r*   r   ServerSentEvent.event       {{r-   c                   V ^8  d   QhRR/# r   r(   )r)   s   "r*   r+   r      s      J r-   c                	    V P                   # r/   )r   r?   s   &r*   r   ServerSentEvent.id   s    xxr-   c                   V ^8  d   QhRR/# )r"   r&   r   r(   )r)   s   "r*   r+   r      r   r-   c                	    V P                   # r/   )r   r?   s   &r*   r   ServerSentEvent.retry   r   r-   c                   V ^8  d   QhRR/# r"   r&   strr(   )r)   s   "r*   r+   r      s      c r-   c                	    V P                   # r/   )r   r?   s   &r*   rR   ServerSentEvent.data   s    zzr-   c                   V ^8  d   QhRR/# )r"   r&   r   r(   )r)   s   "r*   r+   r      s     % %c %r-   c                	B    \         P                  ! V P                  4      # r/   )rT   loadsrR   r?   s   &r*   rT   ServerSentEvent.json   s    zz$))$$r-   c                   V ^8  d   QhRR/# r   r(   )r)   s   "r*   r+   r      s     j j# jr-   c           	     	p    R V P                    RV P                   RV P                   RV P                   R2	# )zServerSentEvent(event=z, data=z, id=z, retry=)r   rR   r   r   r?   s   &r*   __repr__ServerSentEvent.__repr__   s9    '

|7499+U477)S[\`\f\f[gghiir-   )r   r   r   r   )rp   rq   rr   rs   r8   propertyr   r   r   rR   rT   r   r   rv   r(   r-   r*   r   r      s     !  	
  !         % j jr-   r   c                      ] tR t^t$ R]R&   R]R&   R]R&   R]R&   R R	 ltR
 R ltR R ltR R ltR R lt	R R lt
RtR# )
SSEDecoderz	list[str]r   r   r   r   r   _last_event_idc                   V ^8  d   QhRR/# rk   r(   )r)   s   "r*   r+   SSEDecoder.__annotate__   s      $ r-   c                	>    R V n         . V n        R V n        R V n        R # r/   )r   r   r   r   r?   s   &r*   r8   SSEDecoder.__init__   s    
"r-   c                    V ^8  d   QhRRRR/# r"   rX   Iterator[bytes]r&   rJ   r(   )r)   s   "r*   r+   r      s      ? 7P r-   c              #     "   V P                  V4       FJ  pVP                  4        F3  pVP                  R4      pV P                  V4      pV'       g   K/  Vx  K5  	  KL  	  R# 5i)^Given an iterator that yields raw binary data, iterate over it & yield every event encounteredutf-8N)_iter_chunks
splitlinesdecoder7   rX   chunkraw_linelinerY   s   &&    r*   rL   SSEDecoder.iter_bytes   sS     &&x0E!,,.w/kk$'3I	 / 1s   AA$A$c                    V ^8  d   QhRRRR/# )r"   rX   r   r&   r(   )r)   s   "r*   r+   r      s     
 
_ 
 
r-   c              #     "   RpV FC  pVP                  RR7       F*  pW$,          pVP                  R4      '       g   K$  Vx  RpK,  	  KE  	  V'       d   Vx  R# R# 5i)^Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunksr-   TkeependsNs   s   

s   

r   endswithr7   rX   rR   r   r   s   &&   r*   r   SSEDecoder._iter_chunks   s\     E(($(7==!@AAJD	 8  J s   9A AAc                    V ^8  d   QhRRRR/# r"   rX   AsyncIterator[bytes]r&   r   r(   )r)   s   "r*   r+   r      s      *> Ca r-   c                  "   V P                  V4        Rj  xL
  pVP                  4        F4  pVP                  R4      pV P                  V4      pV'       g   K/  V5x  K6  	  KT   LODPR# 5i)r   Nr   )_aiter_chunksr   r   r   s   &&    r*   r   SSEDecoder.aiter_bytes   s`     --h7 	 	%!,,.w/kk$'3I	 /	7s+   A-A*A(A*<A-A-(A**A-c                    V ^8  d   QhRRRR/# )r"   rX   r   r&   r(   )r)   s   "r*   r+   r      s     
 
,@ 
EY 
r-   c                  "   RpV  Rj  xL
  pVP                  RR7       F+  pW$,          pVP                  R4      '       g   K$  V5x  RpK-  	  KM   LHDIT'       d   T5x  R# R# 5i)r   r-   NTr   r   r   r   s   &&   r*   r   SSEDecoder._aiter_chunks   sh     # 	 	%(($(7==!@AAJD	 8	8 J s1   A(AAA3A(A(AA(	A(c                    V ^8  d   QhRRRR/# )r"   r   r   r&   zServerSentEvent | Noner(   )r)   s   "r*   r+   r      s     . .3 .#9 .r-   c                	   V'       g   V P                   '       g5   V P                  '       g#   V P                  '       g   V P                  f   R # \	        V P                   RP                  V P                  4      V P                  V P                  R7      pR V n         . V n        R V n        V# VP                  R4      '       d   R # VP                  R4      w  r4pVP                  R4      '       d
   VR,          pVR8X  d	   WPn         R # VR8X  d   V P                  P                  V4       R # VR8X  d   R	V9   d    R # WPn         R # VR
8X  d    \        V4      V n        R #  R #   \        \        3 d     R # i ; i)N
r   : :   NNr   rR   r    r   )r   r   r   r   r   join
startswith	partitionappendint	TypeError
ValueError)r7   r   rY   	fieldname_values   &&    r*   r   SSEDecoder.decode   s\    ;;;tzzz$:M:M:MRVR]R]Re!kkYYtzz*&&kk	C DKDJDKJ??3"nnS1	eC  "IEK   & JJe$  $u}  ',#  '!!%j   z*  s   E# #E87E8)r   r   r   r   N)rp   rq   rr   rs   ru   r8   rL   r   r   r   r   rv   r(   r-   r*   r   r      s=    

. .r-   r   c                  .    ] tR tRtR R ltR R ltRtR# )r   i+  c                    V ^8  d   QhRRRR/# r   r(   )r)   s   "r*   r+   SSEBytesDecoder.__annotate__-  s      ? 7P r-   c                    R# )r   Nr(   r7   rX   s   &&r*   rL   SSEBytesDecoder.iter_bytes-      r-   c                    V ^8  d   QhRRRR/# r   r(   )r)   s   "r*   r+   r  1  s      $8 =[ r-   c                    R# )zdGiven an async iterator that yields raw binary data, iterate over it & yield every event encounteredNr(   r  s   &&r*   r   SSEBytesDecoder.aiter_bytes1  r  r-   r(   N)rp   rq   rr   rs   rL   r   rv   r(   r-   r*   r   r   +  s     r-   r   c                    V ^8  d   QhRRRR/# )r"   typtyper&   z;TypeGuard[type[Stream[object]] | type[AsyncStream[object]]]r(   )r)   s   "r*   r+   r+   6  s     Q Qd Q'b Qr-   c                    \        V 4      ;'       g    T p\        P                  ! V4      ;'       d    \        V\        \
        34      # )zaTypeGuard for determining whether or not the given type is a subclass of `Stream` / `AsyncStream`)r   inspectisclass
issubclassr   rx   )r  origins   & r*   is_stream_class_typer  6  s6    _##F??6"PPz&6;:O'PPr-   failure_messagec               $    V ^8  d   QhRRRRRR/# )r"   
stream_clsr  r  r   r&   r(   )r)   s   "r*   r+   r+   <  s(         
	r-   c          	     F    ^RI HpHp \        V ^ \	        RW#34      VR7      # )zGiven a type like `Stream[T]`, returns the generic type variable `T`.

This also handles the case where a concrete subclass is given, e.g.
```py
class MyStream(Stream[bytes]):
    ...

extract_stream_chunk_type(MyStream) -> bytes
```
)r   rx   ztuple[type, ...])indexgeneric_basesr  )_base_clientr   rx   r   r   )r  r  r   rx   s   &$  r*   extract_stream_chunk_typer  <  s+     2%-/DE'	 r-   )&
__future__r   rT   r  typesr   typingr   r   r   r   r	   r
   r   r   typing_extensionsr   r   r   r   r   r   httpx_utilsr   r2   r   r   _modelsr   r   r   rx   r   r   r   r  r  r(   r-   r*   <module>r"     s    "    ` ` ` ` `  .0, T]>WR[ >B?%'"+ ?%D&j &jRf fR h  Q #' r-   