+
    Wia9                       ^ RI Ht ^ RIt^ RI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Ht ]	'       d   ^RIHtHt ^RIH t  ]! R	4      t! ! R
 R]PD                  4      t# ! R R]]!,          ]#R7      t$ ! R R]PD                  4      t% ! R R]]!,          ]%R7      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)is_dictextract_type_var_from_base)	AnthropicAsyncAnthropic)FinalRequestOptions_Tc                  ,    ] tR t^t]R R l4       tRtR# )_SyncStreamMetac                    V ^8  d   QhRRRR/#    instancer   returnbool )formats   "S/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/anthropic/_streaming.py__annotate___SyncStreamMeta.__annotate__         # $     c                	r    ^RI Hp \        W4      '       d    \        P                  ! R\
        ^R7       R# R# )   )MessageStreamzUsing `isinstance()` to check if a `MessageStream` object is an instance of `Stream` is deprecated & will be removed in the next major version
stacklevelTF)lib.streamingr*   
isinstancewarningswarnDeprecationWarning)selfr   r*   s   && r#   __instancecheck__!_SyncStreamMeta.__instancecheck__   s2     	1h..MM a"
 r'   r!   N__name__
__module____qualname____firstlineno__r   r3   __static_attributes__r!   r'   r#   r   r           r'   r   c                      ] 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
/# )r   cast_totype[_T]r?   r>   clientr   rD   r@   r   Noner!   )r"   s   "r#   r$   Stream.__annotate__4   s>     + + + !	+
 + /+ 
+r'   c               	    W n         Wn        W0n        W@n        VP	                  4       V n        V P                  4       V n        R # Nr?   _cast_to_clientrA   _make_sse_decoderrC   
__stream__	_iteratorr2   rF   r?   rH   rD   s   &$$$$r#   __init__Stream.__init__4   6     !002*r'   c                   V ^8  d   QhRR/# r   r   r   r!   )r"   s   "r#   r$   rJ   C   s     ) )" )r'   c                	6    V P                   P                  4       # rL   )rR   __next__r2   s   &r#   rZ   Stream.__next__C   s    ~~&&((r'   c                   V ^8  d   QhRR/# r   r   zIterator[_T]r!   )r"   s   "r#   r$   rJ   F   s      , r'   c              #  	<   "   V P                    F  pVx  K	  	  R # 5irL   rR   r2   items   & r#   __iter__Stream.__iter__F   s     NNDJ #s   c                   V ^8  d   QhRR/# )r   r   Iterator[ServerSentEvent]r!   )r"   s   "r#   r$   rJ   J   s     H H7 Hr'   c              #  	   "   V P                   P                  V P                  P                  4       4       R j  xL
  R #  L5irL   )rC   
iter_bytesr?   r[   s   &r#   _iter_eventsStream._iter_eventsJ   s*     ==++DMM,D,D,FGGGs   7AA Ac                   V ^8  d   QhRR/# r^   r!   )r"   s   "r#   r$   rJ   M   s     , ,L ,r'   c              #  	  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V EFC  pVP                  R 8X  d   V! VP                  4       WR7      x  VP                  R8X  gV   VP                  R8X  gE   VP                  R8X  g4   VP                  R8X  g#   VP                  R8X  g   VP                  R8X  dD   VP                  4       p\        V4      '       d   RV9  d   VP                  VR&   V! WaVR7      x  VP                  R	8X  d   K  VP                  R
8X  g   K  VP                  p VP                  4       pT pV P                  P                  VVV P                  R7      h	  VP                  4        R#   \         d'    TP                  ;'       g    RTP                   2p Lli ; i  TP                  4        i ; i5i)
completiondatarF   r?   message_startmessage_deltamessage_stopcontent_block_startcontent_block_deltacontent_block_stoptypepingerrorError code: bodyr?   N)r   r   rN   r?   rO   _process_response_datari   eventjsonr   ro   	Exceptionstatus_code_make_status_errorclose	r2   rF   r?   process_dataiteratorssero   r{   err_msgs	   &        r#   rQ   Stream.__stream__M   s    sDMM*==||::$$&&	99,&CHHJ[[ II0yyO3yyN2yy$99yy$99yy$8888:Dt}}t);'*yyV&DHUU99&99'88DT"xxz%)F ,,99!!% :  =  J NN % T"%(("S"SX=Q=Q<R.ST NNsO   AG5C;G  G  F,0*G  G5,G
GG  GG   G22G5c                   V ^8  d   QhRR/# r   r   r   r!   )r"   s   "r#   r$   rJ   {   s      4 r'   c                	    V # rL   r!   r[   s   &r#   	__enter__Stream.__enter__{   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   rI   r!   )r"   s   "r#   r$   rJ   ~   s2      , " %	
 
r'   c                	&    V P                  4        R # rL   r   r2   r   r   r   s   &&&&r#   __exit__Stream.__exit__~   s     	

r'   c                   V ^8  d   QhRR/# r   r   rI   r!   )r"   s   "r#   r$   rJ      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?   r   r[   s   &r#   r   Stream.close   s     	r'   rN   rO   rC   rR   rA   r?   )r6   r7   r8   r9   __doc____annotations__rA   rT   rZ   rc   ri   rQ   r   r   r   r:   r!   r'   r#   r=   r=   -   sU    T.2H+2+ 26+)H,\ r'   r=   )	metaclassc                  ,    ] tR t^t]R R l4       tRtR# )_AsyncStreamMetac                    V ^8  d   QhRRRR/# r   r!   )r"   s   "r#   r$   _AsyncStreamMeta.__annotate__   r&   r'   c                	r    ^RI Hp \        W4      '       d    \        P                  ! R\
        ^R7       R# R# )r)   )AsyncMessageStreamzUsing `isinstance()` to check if a `AsyncMessageStream` object is an instance of `AsyncStream` is deprecated & will be removed in the next major versionr+   TF)r-   r   r.   r/   r0   r1   )r2   r   r   s   && r#   r3   "_AsyncStreamMeta.__instancecheck__   s2     	6h33MM k"
 r'   r!   Nr5   r!   r'   r#   r   r      r;   r'   r   c                      ] 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# )AsyncStreamzLProvides the core interface to iterate over an asynchronous stream response.r>   r?   Nr@   rA   zSSEDecoder | SSEBytesDecoderrC   rD   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r   rF   rG   r?   r>   rH   r   rD   r@   r   rI   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 # rL   rM   rS   s   &$$$$r#   rT   AsyncStream.__init__   rV   r'   c                   V ^8  d   QhRR/# rX   r!   )r"   s   "r#   r$   r      s     0 0 0r'   c                	R   "   V P                   P                  4       G R j  xL
 #  L5irL   )rR   	__anext__r[   s   &r#   r   AsyncStream.__anext__   s     ^^--////s   '%'c                   V ^8  d   QhRR/# r   r   zAsyncIterator[_T]r!   )r"   s   "r#   r$   r      s      !2 r'   c               	N   "   V P                     R j  xL
  pV5x  K   LDR # 5irL   r`   ra   s   & r#   	__aiter__AsyncStream.__aiter__   s$     .. 	 	$J	.s   %" "	%"%c                   V ^8  d   QhRR/# )r   r   AsyncIterator[ServerSentEvent]r!   )r"   s   "r#   r$   r      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rL   )rC   aiter_bytesr?   )r2   r   s   & r#   ri   AsyncStream._iter_events   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$   r      s     ,$ ,$"3 ,$r'   c               	,  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V  R j  xL
  pVP                  R8X  d   V! VP                  4       WR7      5x  VP                  R8X  gV   VP                  R8X  gE   VP                  R8X  g4   VP                  R8X  g#   VP                  R8X  g   VP                  R8X  dE   VP                  4       p\        V4      '       d   R	V9  d   VP                  VR	&   V! WaVR7      5x  VP                  R
8X  d   K  VP                  R8X  g   EK  VP                  p VP                  4       pT pV P                  P                  VVV P                  R7      h ELK  \         d'    TP                  ;'       g    RTP                   2p L[i ; iED TP                  4       G R j  xL 
  R #   TP                  4       G R j  xL 
  i ; i5i)Nrm   rn   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   rz   )r   r   rN   r?   rO   r|   ri   r}   r~   r   ro   r   r   r   acloser   s	   &        r#   rQ   AsyncStream.__stream__   s    sDMM*==||::$$&&	$% " "c99,&CHHJ[[ II0yyO3yyN2yy$99yy$99yy$8888:Dt}}t);'*yyV&DHUU99&99'88DT"xxz%)F ,,99!!% :  ="6 % T"%(("S"SX=Q=Q<R.ST7 &J //###(//###s   AHG6 GF!GC9G6 G6 &F$9(G6 !G$GGG6 GG6 H.G1/H6H
HHHc                   V ^8  d   QhRR/# r   r!   )r"   s   "r#   r$   r      s      $ r'   c                	   "   V # 5irL   r!   r[   s   &r#   
__aenter__AsyncStream.__aenter__   s
     s   c               (    V ^8  d   QhRRRRRRRR/# r   r!   )r"   s   "r#   r$   r      s2      , " %	
 
r'   c                	B   "   V P                  4       G R j  xL
  R #  L5irL   r   r   s   &&&&r#   	__aexit__AsyncStream.__aexit__   s      jjls   c                   V ^8  d   QhRR/# r   r!   )r"   s   "r#   r$   r      s     % %T %r'   c                V   "   V P                   P                  4       G Rj  xL
  R#  L5ir   )r?   r   r[   s   &r#   r   AsyncStream.close   s      mm""$$$s   )')r   )r6   r7   r8   r9   r   r   rA   rT   r   r   ri   rQ   r   r   r   r:   r!   r'   r#   r   r      sT    V.2H+2**+ 26+0,$\% %r'   r   c                      ] tR tR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# )ServerSentEventi  r}   Nro   idretryc          
     ,    V ^8  d   QhRRRRRRRRRR/# )	r   r}   
str | Nonero   r   r   
int | Noner   rI   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)r2   r}   ro   r   r   s   &$$$$r#   rT   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                   # rL   )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                   # rL   )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                   # rL   )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                   # rL   )r   r[   s   &r#   ro   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      # rL   )r~   loadsro   r[   s   &r#   r~   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}   ro   r   r   r[   s   &r#   __repr__ServerSentEvent.__repr__+  s9    '

|7499+U477)S[\`\f\f[gghiir'   )r   r   r   r   )r6   r7   r8   r9   rT   propertyr}   r   r   ro   r~   r   r   r:   r!   r'   r#   r   r     s     !  	
  !         % j jr'   r   c                      ] tR tR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# )
SSEDecoderi0  z	list[str]r   r   r   r   r   _last_event_idc                   V ^8  d   QhRR/# r   r!   )r"   s   "r#   r$   SSEDecoder.__annotate__6  s      $ r'   c                	>    R V n         . V n        R V n        R V n        R # rL   )r   r   r   r   r[   s   &r#   rT   SSEDecoder.__init__6  s    
"r'   c                    V ^8  d   QhRRRR/# r   r   Iterator[bytes]r   rf   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r2   r   chunkraw_lineliner   s   &&    r#   rh   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   r   r   r   r!   )r"   s   "r#   r$   r   F  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r2   r   ro   r  r	  s   &&   r#   r  SSEDecoder._iter_chunksF  s\     E(($(7==!@AAJD	 8  J s   9A AAc                    V ^8  d   QhRRRR/# r   r   AsyncIterator[bytes]r   r   r!   )r"   s   "r#   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_bytesR  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   r   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   h  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   : :r)   NNr}   ro   r    r   )r   r   r   r   r   join
startswith	partitionappendint	TypeError
ValueError)r2   r	  r   	fieldname_values   &&    r#   r  SSEDecoder.decodeh  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)r6   r7   r8   r9   r   rT   rh   r  r   r  r  r:   r!   r'   r#   r   r   0  s=    

. .r'   r   c                  .    ] tR tRtR R ltR R ltRtR# )rB   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!   r2   r   s   &&r#   rh   SSEBytesDecoder.iter_bytes      r'   c                    V ^8  d   QhRRRR/# r  r!   )r"   s   "r#   r$   r1    s      $8 =[ r'   c                    R# )zdGiven an async iterator that yields raw binary data, iterate over it & yield every event encounteredNr!   r3  s   &&r#   r   SSEBytesDecoder.aiter_bytes  r5  r'   r!   N)r6   r7   r8   r9   rh   r   r:   r!   r'   r#   rB   rB     s     r'   rB   c                    V ^8  d   QhRRRR/# )r   typrv   r   z;TypeGuard[type[Stream[object]] | type[AsyncStream[object]]]r!   )r"   s   "r#   r$   r$     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=   r   )r:  origins   & r#   is_stream_class_typer@    s6    _##F??6"PPz&6;:O'PPr'   failure_messagec               $    V ^8  d   QhRRRRRR/# )r   
stream_clsrv   rA  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=   r   ztuple[type, ...])indexgeneric_basesrA  )_base_clientr=   r   r   r   )rC  rA  r=   r   s   &$  r#   extract_stream_chunk_typerH    s+     2%-/DE'	 r'   ),
__future__r   abcr~   r<  r/   typesr   typingr   r   r   r   r	   r
   r   r   typing_extensionsr   r   r   r   r   r   httpx_utilsr   r   rO   r   r   _modelsr   r   ABCMetar   r=   r   r   r   r   rB   r@  rH  r!   r'   r#   <module>rR     s    " 
     ` ` ` ` `  72, T]ckk *_WR[O _Ds{{ *`%'"+)9 `%F&j &jRf fR h  Q #' r'   