+
    PV-j}  ã                  ó°  € ^ RI Ht ^ RIt^RIHtHt ^RIHt ^RIH	t	 ]P                  '       d2   ^ RIt^ RIt]P                  ]P                  ]P                  3,          t]P                  ]]P"                  3,          t]P&                  . ]P(                  ],          3,          t]P&                  ]P                  ]]P"                  3,          .]P(                  R,          3,          t]P&                  ]P                  ]]P"                  3,          ]].]P(                  R,          3,          tR.tR R ltR	 R
 lt ! R R]4      t ! R R]	4      tR# )é    )ÚannotationsN)ÚRequestÚResponse)ÚAsyncByteStream)ÚAsyncBaseTransportÚASGITransportc               ó   € V ^8„  d   QhRR/# )é   ÚreturnÚbool© )Úformats   "Úg/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/httpx/_transports/asgi.pyÚ__annotate__r      s   € ÷ ñ ˜ñ ó    c                 ód   €  ^ RI p V P                  4       R8X  d   R#  R#   \         d     R# i ; i)r   NÚtrioTF)ÚsniffioÚcurrent_async_libraryÚImportError)r   s    r   Úis_running_trior      sA   € ð	ó 	à×(Ñ(Ó*¨fÔ4Ùð 5ñ
 øô ô Øáðús   ‚   /®/c               ó   € V ^8„  d   QhRR/# )r
   r   ÚEventr   )r   s   "r   r   r   ,   s   € ÷ ñ �eñ r   c                 óv   € \        4       '       d   ^ RIp V P                  ! 4       # ^ RIpVP                  ! 4       # )r   N)r   r   r   Úasyncio)r   r   s     r   Úcreate_eventr   ,   s)   € Ü×ÒÛà�zŠz‹|Ðãà�=Š=‹?Ðr   c                  ó.   € ] tR t^7tR R ltR R ltRtR# )ÚASGIResponseStreamc               ó    € V ^8„  d   QhRRRR/# )r
   Úbodyzlist[bytes]r   ÚNoner   )r   s   "r   r   ÚASGIResponseStream.__annotate__8   s   € ÷ ñ ˜[ð ¨Tñ r   c                	ó   € Wn         R # ©N©Ú_body)Úselfr    s   &&r   Ú__init__ÚASGIResponseStream.__init__8   s   € ØŽ
r   c               ó   € V ^8„  d   QhRR/# )r
   r   ztyping.AsyncIterator[bytes]r   )r   s   "r   r   r"   ;   s   € ÷ #ñ #Ð!<ñ #r   c               	óJ   "  € R P                  V P                  4      5x € R# 5i)r   N)Újoinr&   )r'   s   &r   Ú	__aiter__ÚASGIResponseStream.__aiter__;   s   é € Ø�h‰h�t—z‘zÓ"Õ"ùs   ‚!#r%   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r(   r-   Ú__static_attributes__r   r   r   r   r   7   s   † õ÷#ñ #r   r   c                  ó6   € ] tR t^?tRtRR R lltR R ltRtR# )	r   a›  
A custom AsyncTransport that handles sending requests directly to an ASGI app.

```python
transport = httpx.ASGITransport(
    app=app,
    root_path="/submount",
    client=("1.2.3.4", 123)
)
client = httpx.AsyncClient(transport=transport)
```

Arguments:

* `app` - The ASGI application.
* `raise_app_exceptions` - Boolean indicating if exceptions in the application
   should be raised. Default to `True`. Can be set to `False` for use cases
   such as testing the content of a client 500 response.
* `root_path` - The root path on which the ASGI application should be mounted.
* `client` - A two-tuple indicating the client IP and port of incoming requests.
```
c          
     ó,   € V ^8„  d   QhRRRRRRRRR	R
/# )r
   ÚappÚ_ASGIAppÚraise_app_exceptionsr   Ú	root_pathÚstrÚclientztuple[str, int]r   r!   r   )r   s   "r   r   ÚASGITransport.__annotate__W   s<   € ÷ 
ñ 
àð
ð #ð
ð ð	
ð
  ð
ð 
ñ
r   c                	ó6   € Wn         W n        W0n        W@n        R # r$   )r6   r8   r9   r;   )r'   r6   r8   r9   r;   s   &&&&&r   r(   ÚASGITransport.__init__W   s   € ð ŒØ$8Ô!Ø"ŒØŽr   c               ó    € V ^8„  d   QhRRRR/# )r
   Úrequestr   r   r   r   )r   s   "r   r   r<   c   s&   € ÷ XNñ XNàðXNð 
ñXNr   c              ƒ  	ó0  aaa	a
aaaa"  € \        SP                  \        4      '       g   Q hR RRRR/RRRSP                  RSP                  P
                   UUu. uF  w  r#VP                  4       V3NK  	  uppR	SP                  P                  R
SP                  P                  RSP                  P                  P                  R4      ^ ,          RSP                  P                  RSP                  P                  SP                  P                  3RV P                  RV P                   /pSP                  P#                  4       o	Ro
RoRo. oRo\%        4       oR V	V
V3R llpR VVVVVV3R llp V P'                  WEV4      G Rj  x€L
  SP/                  4       '       g   Q hSf   Q hSf   Q h\1        S4      p\3        SSVR7      # u uppi  LG  \(         d3    T P*                  '       d   h SP-                  4        Sf   RoSf   / o L�i ; i5i)ÚtypeÚhttpÚasgiÚversionz3.0Úhttp_versionz1.1ÚmethodÚheadersÚschemeÚpathÚraw_pathó   ?Úquery_stringÚserverr;   r9   FNc               ó   € V ^8„  d   QhRR/# )r
   r   zdict[str, typing.Any]r   )r   s   "r   r   Ú8ASGITransport.handle_async_request.<locals>.__annotate__†   s   € ÷ 	Mñ 	MÐ4ñ 	Mr   c               “  óÔ   <"  € S'       d   SP                  4       G R j  x€L
  RR/#  SP                  4       G R j  x€L
 p RRRT RR/#  L) L  \         d    RoRRRRRR/u # i ; i5i)	NrB   zhttp.disconnectTzhttp.requestr    r   Ú	more_bodyF)ÚwaitÚ	__anext__ÚStopAsyncIteration)r    Úrequest_body_chunksÚrequest_completeÚresponse_completes    €€€r   ÚreceiveÚ3ASGITransport.handle_async_request.<locals>.receive†   sˆ   øé € ÷  Ø'×,Ñ,Ó.×.Ð.ØÐ 1Ð2Ð2ðQØ0×:Ñ:Ó<×<�ð ˜N¨F°D¸+ÀtÐLÐLñ /ñ =øÜ%ô QØ#'Ð Ø °¸¸[È%ÐPÒPðQüsB   ƒA(ŸA	 A(©A ¼A½A Á	A(ÁA ÁA%Á"A(Á$A%Á%A(c               ó    € V ^8„  d   QhRRRR/# )r
   Úmessagez&typing.MutableMapping[str, typing.Any]r   r!   r   )r   s   "r   r   rP   ”   s   € ÷ 	,ñ 	,Ð Fð 	,È4ñ 	,r   c              “  óž  <"  € V R ,          R8X  d*   S'       d   Q hV R,          oV P                  R. 4      oRoR# V R ,          R8X  dƒ   SP                  4       '       d   Q hV P                  RR4      pV P                  RR	4      pV'       d#   SP                  R
8w  d   SP                  V4       V'       g   SP	                  4        R# R# R# 5i)rB   zhttp.response.startÚstatusrH   Tzhttp.response.bodyr    r   rR   FÚHEADN)ÚgetÚis_setrG   ÚappendÚset)	r\   r    rR   Ú
body_partsr@   rX   Úresponse_headersÚresponse_startedÚstatus_codes	   &  €€€€€€r   ÚsendÚ0ASGITransport.handle_async_request.<locals>.send”   s¶   øé € ð �v�Ð"7Ô7ß+Ð+Ð+à% hÕ/�Ø#*§;¡;¨y¸"Ó#=Ð Ø#'Ò à˜•Ð$8Ô8Ø,×3Ñ3×5Ò5Ð5Ð5Ø—{‘{ 6¨3Ó/�Ø#ŸK™K¨°UÓ;�	ç˜GŸN™N¨fÔ4Ø×%Ñ% dÔ+ç Ø%×)Ñ)Ö+ñ !ñ 9ùs   ƒCšACÁ-CÂ)CÂ7Ciô  )rH   Ústream)Ú
isinstancerj   r   rG   rH   ÚrawÚlowerÚurlrI   rJ   rK   ÚsplitÚqueryÚhostÚportr;   r9   r-   r   r6   Ú	Exceptionr8   rc   ra   r   r   )r'   r@   ÚkÚvÚscoperY   rh   rj   rd   rV   rW   rX   re   rf   rg   s   &f      @@@@@@@r   Úhandle_async_requestÚ"ASGITransport.handle_async_requestc   sî  ÿé € ô ˜'Ÿ.™.¬/×:Ò:Ð:Ð:ð �FØ�Y Ð&Ø˜EØ�g—n‘nØ°W·_±_×5HÒ5HÔIÑ5H©6¨A˜Ÿ™› A›Ñ5HÒIØ�g—k‘k×(Ñ(Ø�G—K‘K×$Ñ$Ø˜Ÿ™×,Ñ,×2Ñ2°4Ó8¸Õ;Ø˜GŸK™K×-Ñ-Ø�w—{‘{×'Ñ'¨¯©×)9Ñ)9Ð:Ø�d—k‘kØ˜Ÿ™ð
ˆð  &Ÿn™n×6Ñ6Ó8ÐØ Ðð ˆØÐØˆ
Ø ÐÜ(›NÐ÷	Mò 	M÷	,õ 	,ð*
	&Ø—(‘(˜5¨4Ó0×0Ð0ð !×'Ñ'×)Ò)Ð)Ð)ØÒ&Ð&Ð&ØÒ+Ð+Ð+ä# JÓ/ˆä˜Ð-=ÀfÔMÐMùóY Jñv 1øÜô 	&Ø×(×(Ð(Øà×!Ñ!Ô#ØÒ"Ø!�ØÒ'Ø#%Ð ùð	&üsU   ŠAHÁGÁ8C>HÅ7G ÆGÆG ÆHÆ'-HÇG ÇHÇ3HÈHÈHÈH)r6   r;   r8   r9   N)TÚ )z	127.0.0.1é{   )r/   r0   r1   r2   Ú__doc__r(   rw   r3   r   r   r   r   r   ?   s   † ñ÷.
÷XNñ XNr   )Ú
__future__r   ÚtypingÚ_modelsr   r   Ú_typesr   Úbaser   ÚTYPE_CHECKINGr   r   ÚUnionr   ÚMutableMappingr:   ÚAnyÚ_MessageÚCallableÚ	AwaitableÚ_ReceiveÚ_Sendr7   Ú__all__r   r   r   r   r   r   r   Ú<module>r‹      s  ðÝ "ã ç 'Ý $Ý $à	××ÐÛãà�L‰L˜Ÿ™¨¯
©
Ð2Õ3€Eð × Ñ   f§j¡j Õ1€Ø�?‰?˜2˜v×/Ñ/°Õ9Ð9Õ:€Ø�‰Ø×Ñ˜3 §
¡
˜?Õ+Ð,¨f×.>Ñ.>¸tÕ.DÐDõ	€ð �?‰?Ø×Ñ˜3 §
¡
˜?Õ+¨X°uÐ=¸v×?OÑ?OÐPTÕ?UÐUõ€ð Ð
€õõô#˜ô #ô|NÐ&ö |Nr   