+
    NV-jV(  ã                  ó°  € ^ RI Ht ^ RIHtHtHtHtHtHt ^ RI	H
t
Ht ^ RIt^ RIHt ^ RIHtHt ^ RIHt ^ RIHtHtHtHtHt ]].]],          3,          t]]].]],          3,          t]]]]]
3,          ,          R3,          t]]],          ],          ]]]
3,          ,          ,          t ]! R	4      t! ! R
 R]4      t" ! R R4      t# ! R R]4      t$R# )é    )Úannotations)ÚAsyncGeneratorÚAsyncIterableÚ	AwaitableÚCallableÚMappingÚMutableMapping)ÚAnyÚTypeVarN)Úcreate_collapsing_task_group)ÚClientDisconnectÚRequest)ÚResponse)ÚASGIAppÚMessageÚReceiveÚScopeÚSendÚTc                  ó>   a € ] tR t^tRtR V 3R lltR R ltRtV ;t# )Ú_CachedRequesta  
If the user calls Request.body() from their dispatch function
we cache the entire request body in memory and pass that to downstream middlewares,
but if they call Request.stream() then all we do is send an
empty body so that downstream things don't hang forever.
c               ó    € V ^8„  d   QhRRRR/# )é   Úscoper   Úreceiver   © )Úformats   "Új/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/starlette/middleware/base.pyÚ__annotate__Ú_CachedRequest.__annotate__   s   € ÷ 0ñ 0˜eð 0¨gñ 0ó    c                	ól   <€ \         SV `  W4       R V n        R V n        V P	                  4       V n        R# )FN)ÚsuperÚ__init__Ú_wrapped_rcv_disconnectedÚ_wrapped_rcv_consumedÚstreamÚ_wrapped_rc_stream)Úselfr   r   Ú	__class__s   &&&€r   r$   Ú_CachedRequest.__init__   s.   ø€ Ü‰Ñ˜Ô(Ø).ˆÔ&Ø%*ˆÔ"Ø"&§+¡+£-ˆÖr!   c               ó   € V ^8„  d   QhRR/# ©r   Úreturnr   r   )r   s   "r   r   r    "   s   € ÷ ;3ñ ;3 wñ ;3r!   c              ƒ  	ó�  "  € V P                   '       d   R R/# V P                  '       db   V P                  '       d   RV n         R R/# V P                  4       G Rj  x€L
 pVR ,          R8w  d   \	        RVR ,           24      hRV n         V# \        V RR4      e   RV n        R RRV P                  RR	/# V P                  '       d   RV n        R RRR
RR	/#  V P                  4       pVP                  4       G Rj  x€L
 pV P                  V n        R RRVRV P                  '       * /#  LÊ L.  \         d    RT n         R R/u # i ; i5i)Útypeúhttp.disconnectTNzUnexpected message received: Ú_bodyzhttp.requestÚbodyÚ	more_bodyFr!   )r%   r&   Ú_is_disconnectedr   ÚRuntimeErrorÚgetattrr2   Ú_stream_consumedr'   Ú	__anext__r   )r)   Úmsgr'   Úchunks   &   r   Úwrapped_receiveÚ_CachedRequest.wrapped_receive"   sy  é € à×)×)Ð)ð Ð-Ð.Ð.à×%×%Ð%ð ×$×$Ð$ð 26�Ô.ØÐ 1Ð2Ð2ð Ÿ™›×&ˆCØ�6�{Ð/Ô/ô #Ð%BÀ3ÀvÅ;À-Ð#PÓQÐQØ-1ˆDÔ*ØˆJô �4˜ $Ó'Ò3à)-ˆDÔ&à˜Ø˜Ÿ
™
Ø˜Uðð ð
 ×"×"Ð"ð *.ˆDÔ&à˜Ø˜Ø˜Uðð ð3ØŸ™›�Ø$×.Ñ.Ó0×0�Ø-1×-BÑ-B�Ô*à˜NØ˜EØ T×%:Ñ%:Ô!:ðð ñC 'ñ> 1øô $ô 3Ø15�Ô.ØÐ 1Ð2Ò2ð3üsX   ‚(E«E½EÁD&ÁA)EÃEÃ#D* Ã9D(Ã:+D* Ä%EÄ(D* Ä*EÅ EÅEÅE)r(   r&   r%   )	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r$   r<   Ú__static_attributes__Ú__classcell__)r*   s   @r   r   r      s   ø† ñ÷0ð 0÷;3ó ;3r!   r   c                  ó>   € ] tR t^`tR	R R lltR R ltR R ltRtR# )
ÚBaseHTTPMiddlewareNc               ó$   € V ^8„  d   QhRRRRRR/# )r   Úappr   ÚdispatchzDispatchFunction | Noner.   ÚNoner   )r   s   "r   r   ÚBaseHTTPMiddleware.__annotate__a   s(   € ÷ Mñ M˜Gð MÐ/Fð MÐRVñ Mr!   c                	óN   € Wn         Vf   V P                  V n        R # TV n        R # ©N)rH   rI   Údispatch_func)r)   rH   rI   s   &&&r   r$   ÚBaseHTTPMiddleware.__init__a   s   € ØŒØ.6Ò.>˜TŸ]™]ˆÖÀHˆÖr!   c               ó(   € V ^8„  d   QhRRRRRRRR/# ©	r   r   r   r   r   Úsendr   r.   rJ   r   )r   s   "r   r   rK   e   s.   € ÷ añ a Eð a°Gð aÀ4ð aÈDñ ar!   c              ƒ  	ó  a aaa	a
aaaa"  € SR ,          R8w  d   S P                  SW#4      G Rj  x€L
  R# \        SV4      pVP                  o\        P                  ! 4       oRoRo	R VV	V
VVV VVV3	R llp\        P
                  ! 4       pVw  oo
S
;_uu_ 4        S;_uu_ 4        \        4       ;_uu_4       GRj  x€L
 oS P                  WE4      G Rj  x€L
 pV! SSV4      G Rj  x€L
  SP                  4        S
P                  4        RRR4      GRj  x€L
  RRR4       RRR4       Se   S	'       g   ShR# R#  EL L„ Lm L] L/  + GRj  x€L 
 '       g   i     LF; i  + '       g   i     LQ; i  + '       g   i     L\; i5i)r0   ÚhttpNFc               ó    € V ^8„  d   QhRRRR/# )r   Úrequestr   r.   r   r   )r   s   "r   r   Ú1BaseHTTPMiddleware.__call__.<locals>.__annotate__p   s   € ÷ K	ñ K	 Wð K	°ñ K	r!   c              “  óB  <	aa"  € R  VV3R lloR V3R lloR VVVVVV3R llpSP                  V4        S
P                  4       G Rj  x€L
 pVP                  RR4      pVR,          R	8X  d   Ve   S
P                  4       G Rj  x€L
 pTR,          R8X  g   Q hR T
3R llp\        TR,          T! 4       TR7      pTR,          Tn	        T#  Lƒ LI  \        P                   d4    Se$   R
o	SSP
                  ;'       g    SP                  h\        R4      hi ; i5i)c               ó   € V ^8„  d   QhRR/# r-   r   )r   s   "r   r   ÚDBaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.__annotate__q   s   € ÷ ñ °ñ r!   c               “  ó”  <a"  € SP                  4       '       d   R R/# \        P                  ! 4       ;_uu_4       GRj  x€L
 oR V3R llp SP                  V SP                  4       V ! S4      G Rj  x€L
 pRRR4      GRj  x€L
  SP                  4       '       d   R R/# X#  Le L2 L$  + GRj  x€L 
 '       g   i     L;; i5i)r0   r1   Nc               ó    € V ^8„  d   QhRRRR/# )r   ÚfunczCallable[[], Awaitable[T]]r.   r   r   )r   s   "r   r   ÚcBaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.receive_or_disconnect.<locals>.__annotate__w   s   € ÷ &ñ &Ð)Cð &Èñ &r!   c              “  óf   <"  € V ! 4       G R j  x€L
 pSP                   P                  4        V#  L 5irM   )Úcancel_scopeÚcancel)r]   ÚresultÚ
task_groups   & €r   ÚwrapÚ[BaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.receive_or_disconnect.<locals>.wrapw   s+   øé € Ù'+£v§˜Ø"×/Ñ/×6Ñ6Ô8Ø%˜ñ ".ùs   ƒ1Ž/�!1)Úis_setÚanyioÚcreate_task_groupÚ
start_soonÚwait)rd   Úmessagerc   Úresponse_sentr<   s     @€€r   Úreceive_or_disconnectÚMBaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.receive_or_disconnectq   s¦   ùé € Ø ×'Ñ'×)Ò)Ø"Ð$5Ð6Ð6ä ×2Ò2×4×4Ô4¸
÷&ð &ð
 ×)Ñ)¨$°×0BÑ0BÔCÙ$(¨Ó$9×9�G÷ 5×4ð !×'Ñ'×)Ò)Ø"Ð$5Ð6Ð6à�ñ 5ñ :÷ 5×4×4Ò4üse   „<CÁ B&ÁCÁ1B,Á5B(Á6B,Á:CÂB*ÂCÂ CÂ(B,Â*CÂ,C	Â2B5Â3
C	Â>C	Ã Cc               ó    € V ^8„  d   QhRRRR/# )r   rk   r   r.   rJ   r   )r   s   "r   r   rZ   „   s   € ÷ ñ ¨Wð ¸ñ r!   c              “  ó€   <"  €  SP                  V 4      G R j  x€L
  R #  L  \        P                   d     R # i ; i5irM   )rR   rg   ÚBrokenResourceError)rk   Úsend_streams   &€r   Úsend_no_errorÚEBaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.send_no_error„   s6   øé € ðØ%×*Ñ*¨7Ó3×3Ô3øÜ×0Ñ0ô âðüs(   ƒ>…" ™ š" ž> " ¢;·>º;»>c               ó   € V ^8„  d   QhRR/# )r   r.   rJ   r   )r   s   "r   r   rZ   ‹   s   € ÷ &ñ & ñ &r!   c               “  óÎ   <"  € S;_uu_ 4         SP                  SSS4      G R j  x€L
  R R R 4       R #  L  \         d   p T o R p ? LR p ? ii ; i  + '       g   i     R # ; i5irM   )rH   Ú	Exception)ÚexcÚapp_excrm   r   r)   rs   rr   s    €€€€€€r   ÚcoroÚ<BaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.coro‹   sQ   øé € ÷ !’[ð&Ø"Ÿh™h uÐ.CÀ]ÓS×SÐS÷ !‘[áSøÜ$ô &Ø"%�ûð&ú÷ !—[�[üsH   ƒA%ŽA�7¦5§7«
A%µ7·AÁA	ÁAÁ	AÁAÁA"	Á	A%NÚinfor0   úhttp.response.debugTzNo response returned.úhttp.response.startc               ó   € V ^8„  d   QhRR/# )r   r.   ÚBodyStreamGeneratorr   )r   s   "r   r   rZ   ­   s   € ÷ 
ñ 
Ð':ñ 
r!   c                ó  <"  € S  R j  x€L
  p V R,          R8X  d	   V 5x €  R # V R,          R8X  g   Q RV  24       hV P                  RR4      pV'       d   V5x € V P                  RR4      '       d   Kq   R #  LoDpR # 5i)	Nr0   zhttp.response.pathsendúhttp.response.bodyzUnexpected message: r3   r!   r4   F)Úget)rk   r3   Úrecv_streams     €r   Úbody_streamÚCBaseHTTPMiddleware.__call__.<locals>.call_next.<locals>.body_stream­   s   øé € Ù%0÷ 	ð 	˜'Ø˜v•Ð*BÔBØ%›ÚØ" 6�?Ð.BÔBÐdÐFZÐ[bÐZcÐDdÓdÐBØ"Ÿ;™; v¨sÓ3�DßØ"›
Ø"Ÿ;™; {°E×:Ô:Úñ	¢[ùs2   ƒA?†A<ŠA:‹A<ŽA	A?ÁA?Á7A?Á:A<Á<A?Ústatus)Ústatus_codeÚcontentr|   Úheaders)
ri   r   rƒ   rg   ÚEndOfStreamÚ	__cause__Ú__context__r6   Ú_StreamingResponseÚraw_headers)rV   rz   rk   r|   r…   Úresponserm   rs   ry   Úexception_already_raisedr„   rl   r   r)   rr   rc   r<   s   &     @@€€€€€€€€€r   Ú	call_nextÚ.BaseHTTPMiddleware.__call__.<locals>.call_nextp   s  úé € ÷ñ ÷&ð ÷&õ &ð ×!Ñ! $Ô'ð<Ø +× 3Ñ 3Ó 5×5�Ø—{‘{ 6¨4Ó0�Ø˜6•?Ð&;Ô;ÀÒ@PØ$/×$7Ñ$7Ó$9×9�Gð" ˜6•?Ð&;Ô;Ð;Ð;÷
ð 
ô *°g¸hÕ6GÑQ\ÓQ^ÐeiÔjˆHØ#*¨9Õ#5ˆHÔ ØˆOñI 6ñ :øÜ×$Ñ$ô <ØÒ&à/3Ð,ð " w×'8Ñ'8×'OÐ'O¸G×<OÑ<OÐOÜ"Ð#:Ó;Ð;ð<üsG   …3D¹C ÁCÁ;C ÂCÂ	C ÂADÃC ÃC Ã.DÄDÄD)
rH   r   r<   rg   ÚEventÚcreate_memory_object_streamr   rN   ÚsetÚclose)r)   r   r   rR   rV   r’   Ústreamsr�   ry   r‘   r„   rl   rr   rc   r<   s   ff&&    @@@@@@@r   Ú__call__ÚBaseHTTPMiddleware.__call__e   s.  ÿøé € Ø��=˜FÔ"Ø—(‘(˜5 'Ó0×0Ð0Ùä  ¨Ó0ˆØ!×1Ñ1ˆÜŸš›ˆØ$(ˆØ#(Ð ÷K	÷ K	ð K	ôZ ?D×>_Ò>_Ó>aˆØ#*Ñ ˆ�[ßŠ[Ÿ+š+Ü3×5×5Ô5¸Ø!%×!3Ñ!3°GÓ!G×G�Ù˜u o°tÓ<×<Ð<Ø×!Ñ!Ô#Ø×!Ñ!Ô#÷	 6×5÷ &�[ð Ò×'?ØˆMñ (@Ñò} 1ñr 6ÙGÙ<÷ 6×5×5Ò5ú÷ &Ÿ+ú�[�[üs¸   ‹$F¯E °A,FÂE:Â'E'	Â>EÂ?E'	ÃEÃEÃEÃ)EÃ*$EÄE'	ÄE	ÄE'	ÄE:Ä&FÄ:FÅE'	ÅEÅEÅ	E'	ÅE$ÅEÅ
E$ÅE$ÅE'	Å'E7Å2E:Å:F
	ÆFc               ó$   € V ^8„  d   QhRRRRRR/# )r   rV   r   r’   ÚRequestResponseEndpointr.   r   r   )r   s   "r   r   rK   È   s#   € ÷ $ñ $ gð $Ð:Qð $ÐV^ñ $r!   c              ƒ  	ó   "  € \        4       h5irM   )ÚNotImplementedError)r)   rV   r’   s   &&&r   rI   ÚBaseHTTPMiddleware.dispatchÈ   s   é € Ü!Ó#Ð#ùs   ‚)rH   rN   rM   )r>   r?   r@   rA   r$   r™   rI   rC   r   r!   r   rF   rF   `   s   † ÷Mõa÷F$ñ $r!   rF   c                  ó2   € ] tR t^ÌtRR R lltR R ltRtR# )rŽ   Nc               ó0   € V ^8„  d   QhRRRRRRRRR	R
RR/# )r   r‰   ÚAsyncContentStreamrˆ   ÚintrŠ   zMapping[str, str] | NoneÚ
media_typez
str | Noner|   zMapping[str, Any] | Noner.   rJ   r   )r   s   "r   r   Ú_StreamingResponse.__annotate__Í   sF   € ÷ ñ à#ðð ðð *ð	ð
 ðð 'ðð 
ñr!   c                	óf   € WPn         Wn        W n        W@n        V P	                  V4       R V n        R # rM   )r|   Úbody_iteratorrˆ   r¤   Úinit_headersÚ
background)r)   r‰   rˆ   rŠ   r¤   r|   s   &&&&&&r   r$   Ú_StreamingResponse.__init__Í   s/   € ð Œ	Ø$ÔØ&ÔØ$ŒØ×Ñ˜'Ô"ØˆŽr!   c               ó(   € V ^8„  d   QhRRRRRRRR/# rQ   r   )r   s   "r   r   r¥   Ü   s(   € ÷ $ñ $ Eð $°Gð $À4ð $ÈDñ $r!   c           	   ƒ  	ó  "  € V P                   e   V! RRRV P                   /4      G R j  x€L
  V! RRRV P                  RV P                  /4      G R j  x€L
  RpV P                    R j  x€L
  p\	        V\
        4      '       d   RpV! V4      G R j  x€L
  K4  V! RR	R
VRR/4      G R j  x€L
  KL   Lˆ L` LK L$ LDPT'       d   T! RR	R
RRR/4      G R j  x€L 
  T P                  '       d   T P                  4       G R j  x€L 
  R # R # 5i)Nr0   r}   r|   r~   r‡   rŠ   TFr‚   r3   r4   r!   )r|   rˆ   r�   r§   Ú
isinstanceÚdictr©   )r)   r   r   rR   Úshould_close_bodyr;   s   &&&&  r   r™   Ú_StreamingResponse.__call__Ü   s  é € Ø�9‰9Ò Ù˜Ð 5°v¸t¿y¹yÐIÓJ×JÐJÙàÐ-Ø˜$×*Ñ*Ø˜4×+Ñ+ðó
÷ 	
ð 	
ð !ÐØ×-Ò-÷ 	Yð 	Y�%Ü˜%¤×&Ò&à$)Ð!Ù˜5“k×!Ð!ÙÙ˜Ð 4°f¸eÀ[ÐRVÐWÓX×XÒXñ! Kñ	
ñ	Yñ "áXð .÷ Ù˜Ð 4°f¸cÀ;ÐPUÐVÓW×WÑWà�?�?ˆ?Ø—/‘/Ó#×#Ó#ñ ùs�   ‚(DªB3«)DÁB5ÁDÁ'B=Á+B7Á,B=Á/%DÂB9ÂDÂ,B;Â-DÂ5DÂ7B=Â9DÂ;DÂ=DÃDÃCÃDÃ/DÄDÄ	D)r©   r§   r|   r¤   rˆ   )éÈ   NNN)r>   r?   r@   rA   r$   r™   rC   r   r!   r   rŽ   rŽ   Ì   s   † ÷÷$ñ $r!   rŽ   )%Ú
__future__r   Úcollections.abcr   r   r   r   r   r	   Útypingr
   r   rg   Ústarlette._utilsr   Ústarlette.requestsr   r   Ústarlette.responsesr   Ústarlette.typesr   r   r   r   r   rœ   ÚDispatchFunctionÚbytesÚstrr€   Ú
memoryviewr¢   r   r   rF   rŽ   r   r!   r   Ú<module>r½      sÇ   ðÝ "ç g× gß ã å 9ß 8Ý (ß BÕ Bà" G 9¨i¸Õ.AÐ#AÕBÐ Ø˜WÐ&=Ð>À	È(Õ@SÐSÕTÐ Ø$ U¨^¸CÀ¸HÕ-EÕ%EÀtÐ%KÕLÐ Ø" 3¨¥;°Õ#;¸nÈSÐRUÈXÕ>VÕ#VÕWÐ ÙˆCƒL€ôI3�Wô I3÷Xi$ñ i$ôX($˜ö ($r!   