+
    TŎiN/              	           ^ RI t ^ RIHt ^ RIHtHtHtHt ^RIH	t	 ^RI
HtHtHtHtHt ^RIHtHtHtHtHt ^RIHtHt ^RIHt ^R	IHtHtHt  ! R
 R]	]]]]3,          ,          4      tR# )    N)suppress)AnyOptionalTupleUnion)BaseProtocol)ClientConnectionErrorClientOSErrorClientPayloadErrorServerDisconnectedErrorSocketTimeoutError)_EXC_SENTINELEMPTY_BODY_STATUS_CODESBaseTimerContextset_exception
set_result)HttpResponseParserRawResponseMessage)HttpProcessingError)EMPTY_PAYLOAD	DataQueueStreamReaderc                   B  a a ] tR t^t oRtV3R lR lt]V3R lR l4       t]V3R lR l4       t]V3R lR	 l4       t	V3R
 lR lt
V3R lR ltV3R lR ltV3R lR ltV3R lV 3R lltV3R lR ltV3R lV 3R lltV3R lV 3R llt]3V3R lV 3R llltV3R lR ltRRR R!R"R!R#R$R%RR&R<R'^R(R)R*R)/	V3R+ lR, lltV3R- lR. ltV3R/ lR0 ltV3R1 lR2 lt]V3R3 lR4 l4       t]P4                  V3R5 lR6 l4       tV3R7 lR8 ltV3R9 lR: ltR;tVtV ;t# )=ResponseHandlerz8Helper class to adapt between Protocol and StreamReader.c                8   < V ^8  d   QhRS[ P                  RR/# )   loopreturnN)asyncioAbstractEventLoop)format__classdict__s   "c/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/client_proto.py__annotate__ResponseHandler.__annotate__   s!     - -W66 -4 -    c                   \         P                  ! WR 7       \        P                  ! W4       RV n        RV n        RV n        RV n        RV n        RV n        RV n	        RV n
        RV n        RV n        ^V n        RV n        RV n        R# ))r   FNr&   )r   __init__r   _should_close_payload_skip_payload_payload_parser_timer_tail	_upgraded_parser_read_timeout_read_timeout_handle_timeout_ceil_threshold_closed_connection_lost_called)selfr   s   &&r#   r(   ResponseHandler.__init__   s    d.4&"04"#
59.2CG!89$:>',$r&   c                V   < V ^8  d   QhRS[ RS[P                  R,          3,          /# r   r   N)r   r   Future)r!   r"   s   "r#   r$   r%   5   s'      dGNN4$889 r&   c                    V P                   f2   V P                  '       g    V P                  P                  4       V n         V P                   # )a  Future that is set when the connection is closed.

This property returns a Future that will be completed when the connection
is closed. The Future is created lazily on first access to avoid creating
futures that will never be awaited.

Returns:
    - A Future[None] if the connection is still open or was closed after
      this property was accessed
    - None if connection_lost() was already called before this property
      was ever accessed (indicating no one is waiting for the closure)
)r4   r5   _loopcreate_futurer6   s   &r#   closedResponseHandler.closed4   s7     <<(D(D(D::335DL||r&   c                    < V ^8  d   QhRS[ /# r   r   bool)r!   r"   s   "r#   r$   r%   G   s      $ r&   c                    V P                   # N)r/   r>   s   &r#   upgradedResponseHandler.upgradedF   s    ~~r&   c                    < V ^8  d   QhRS[ /# rB   rC   )r!   r"   s   "r#   r$   r%   K   s     	
 	
d 	
r&   c                v   \        V P                  ;'       g    V P                  R J;'       d(    V P                  P                  4       '       * ;'       ga    V P                  ;'       gM    V P
                  R J;'       g7    V P                  R J;'       g!    V P                  ;'       g    V P                  4      # rF   )	rD   r)   r*   is_eofr/   
_exceptionr,   _bufferr.   r>   s   &r#   should_closeResponseHandler.should_closeJ   s      T)HH$--2F2F2H.H ~~  d*  ##4/	 
 ||  zz
 	
r&   c                   < V ^8  d   QhRR/# r9    )r!   r"   s   "r#   r$   r%   V   s     " "T "r&   c                    R V n         R# TN)r)   r>   s   &r#   force_closeResponseHandler.force_closeV   s
    !r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%   Y        ! !t !r&   c                    R V n         V P                  pVe1   VP                  4        R V n        R V n        V P	                  4        R # R # rF   )rL   	transportcloser*   _drop_timeoutr6   rY   s   & r#   rZ   ResponseHandler.closeY   A    NN	 OO!DN DM 	 !r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%   b   rW   r&   c                    R V n         V P                  pVe1   VP                  4        R V n        R V n        V P	                  4        R # R # rF   )rL   rY   abortr*   r[   r\   s   & r#   ra   ResponseHandler.abortb   r^   r&   c                    < V ^8  d   QhRS[ /# rB   rC   )r!   r"   s   "r#   r$   r%   k   s     N Nd Nr&   c                l    V P                   R J;'       d     V P                   P                  4       '       * # rF   )rY   
is_closingr>   s   &r#   is_connectedResponseHandler.is_connectedk   s)    ~~T)MM$..2K2K2M.MMr&   c                4   < V ^8  d   QhRS[ S[,          RR/# )r   excr   N)r   BaseException)r!   r"   s   "r#   r$   r%   n   s$     I. I.8M#: I.t I.r&   c                  < R V n         V P                  4        TpTpVRJ pV P                  eJ   V'       d   \        V P                  R4       M*Vf   Q h\	        V P                  \        RV: 24      V4       V P                  e;   \        \        4      ;_uu_ 4        V P                  P                  4        RRR4       RpV P                  e    V P                  P                  4       pV P                  4       '       gj   \        V\        4      '       d   \!        VP"                  !  pV'       d   \%        V4      pV'       d   \&        MTpVf   Q hVf   Q hV P	                  W84       R V n        RV n
        RV n        RV n        RV n        \,        S	V `]  V4       R#   + '       g   i     L; i  \         dQ   pT P                  e8   RT: 2pT'       g
   T: RT: 2p\	        T P                  \        T4      T4        Rp?ELRp?ii ; i)TNzConnection lost: z#Response payload is not completed: z. F)r5   r[   r4   r   r   r	   r,   r   	Exceptionfeed_eofr0   r*   r   rK   
isinstanceOSErrorr
   argsr   r   r)   _reading_pausedsuperconnection_lost)
r6   ri   original_connection_errorreraised_excconnection_closed_cleanlyuncompletedunderlying_excclient_payload_exc_msgunderlying_non_eof_exc	__class__s
   &&       r#   rs   ResponseHandler.connection_lostn   s   '+$$'!0$=$E!<<# )4<<.0<<<LL)+,E+IJ . +)$$$$--/ % <<#"ll335" {{}}3W==,.G.L.LM(6{C
 - . #
 *555+++|D!#$-[ %$  ==,=n=PQ + 5598<> / "*+AB&s*   FF1 F.	1H<H)HHc                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%      s      d r&   c                &    V P                  4        R # rF   )r[   r>   s   &r#   eof_receivedResponseHandler.eof_received   s    r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%      s      t r&   c                D   < \         SV `  4        V P                  4        R # rF   )rr   pause_readingr[   r6   r{   s   &r#   r   ResponseHandler.pause_reading   s    r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%      s     # # #r&   c                D   < \         SV `  4        V P                  4        R # rF   )rr   resume_reading_reschedule_timeoutr   s   &r#   r   ResponseHandler.resume_reading   s       "r&   c                *   < V ^8  d   QhRS[ RS[ RR/# )r   ri   	exc_causer   N)rj   )r!   r"   s   "r#   r$   r%      s)     . .. !. 
	.r&   c                T   < R V n         V P                  4        \        SV `  W4       R# rS   )r)   r[   rr   r   )r6   ri   r   r{   s   &&&r#   r   ResponseHandler.set_exception   s&    
 "c-r&   c                *   < V ^8  d   QhRS[ RS[ RR/# )r   parserpayloadr   N)r   )r!   r"   s   "r#   r$   r%      s"     % % %s %t %r&   c                    W n         Wn        V P                  4        V P                  '       d'   V P                  R uq0n        V P	                  V4       R# R# )r&   N)r*   r,   r[   r.   data_received)r6   r   r   datas   &&& r#   
set_parserResponseHandler.set_parser   sG      %:::#zz3D*t$ r&   timerNskip_payloadFread_until_eofauto_decompressTread_timeoutread_bufsizetimeout_ceil_thresholdmax_line_sizei  max_field_sizec                t   < V ^8  d   QhRS[ S[,          RS[RS[RS[RS[ S[,          RS[RS[RS[R	S[R
R/
# )r   r   r   r   r   r   r   r   r   r   r   N)r   r   rD   floatint)r!   r"   s   "r#   r$   r%      s{     "% "% ()"% 	"%
 "% "% uo"% "% !&"% "% "% 
"%r&   c       	            W n         WPn        Wpn        \        V V P                  VV\
        V'       * VVVV	R 7
      V n        V P                  '       d'   V P                  Ruqn        V P                  V
4       R# R# ))r   payload_exceptionresponse_with_bodyr   r   r   r   r&   N)	r+   r1   r3   r   r<   r   r0   r.   r   )r6   r   r   r   r   r   r   r   r   r   r   s   &$$$$$$$$$ r#   set_response_params#ResponseHandler.set_response_params   su     *)'=$)JJ0#//)+')
 :::#zz3D*t$ r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%     s     - -t -r&   c                h    V P                   e$   V P                   P                  4        R V n         R # R # rF   )r2   cancelr>   s   &r#   r[   ResponseHandler._drop_timeout  s-    $$0%%,,.(,D% 1r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%     s     
- 
-T 
-r&   c                    V P                   pV P                  e   V P                  P                  4        V'       d-   V P                  P	                  WP
                  4      V n        R # R V n        R # rF   )r1   r2   r   r<   
call_later_on_read_timeout)r6   timeouts   & r#   r   #ResponseHandler._reschedule_timeout  sX    $$$$0%%,,.(,

(=(=..)D% )-D%r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%     s     # #t #r&   c                &    V P                  4        R # rF   )r   r>   s   &r#   start_timeoutResponseHandler.start_timeout  s      "r&   c                0   < V ^8  d   QhRS[ S[,          /# rB   r   r   )r!   r"   s   "r#   r$   r%     s     " "huo "r&   c                    V P                   # rF   r1   r>   s   &r#   r   ResponseHandler.read_timeout  s    !!!r&   c                4   < V ^8  d   QhRS[ S[,          RR/# )r   r   r   Nr   )r!   r"   s   "r#   r$   r%     s     * *% *T *r&   c                    Wn         R # rF   r   )r6   r   s   &&r#   r   r     s    )r&   c                   < V ^8  d   QhRR/# r9   rQ   )r!   r"   s   "r#   r$   r%     s     . .$ .r&   c                    \        R 4      pV P                  V4       V P                  e   \        V P                  V4       R# R# )z#Timeout on reading data from socketN)r   r   r*   )r6   ri   s   & r#   r    ResponseHandler._on_read_timeout  s8     !FG3==$$--- %r&   c                $   < V ^8  d   QhRS[ RR/# )r   r   r   N)bytes)r!   r"   s   "r#   r$   r%   #  s     D% D%% D%D D%r&   c                   V P                  4        V'       g   R # V P                  eO   V P                  P                  V4      w  r#V'       d(   R V n        R V n        V'       d   V P	                  V4       R # V P
                  '       g   V P                  f   V ;P                  V,          un        R #  V P                  P                  V4      w  rEpYPn        R pT Fx  w  rT	P"                  '       d   RT n        Yn        T P&                  '       g   T	P                  \(        9   d   T P                  T	\*        3^ 4       Ke  T P                  Y3^ 4       Kz  	  Te7   T\*        Jd   TP-                  T P.                  4       MT P/                  4        T'       d   T'       d   T P	                  T4       R # R # R #   \         d   pT P                  e   T P                  P                  4        \        T\        4      '       d.   \        TP                  TP                  TP                  R7      pM
\        4       pT P!                  Yv4        R p?R # R p?ii ; i)N)codemessageheadersT)r   r,   	feed_datar*   r   r/   r0   r.   rj   rY   rZ   rn   r   r   r   r   r   rN   r)   r+   r   r   on_eofr[   )
r6   r   eoftailmessagesrG   rx   ri   r   r   s
   &&        r#   r   ResponseHandler.data_received#  s     " +,,66t<IC $'+$&&t,>>>T\\1JJ$J	'+||'='=d'C$H& "*. (G###%)"#M!!!W\\5L%L7;115 !) 
 m+t112""$t$ 8U  	~~) $$&.*=>>)',,*22*22 *+s3!	s   3F8 8IBII)r4   r5   rL   r0   r*   r,   r1   r2   rq   r)   r+   r.   r3   r-   r/   rY   i   ) __name__
__module____qualname____firstlineno____doc__r(   propertyr?   rG   rN   rT   rZ   ra   rf   rs   r   r   r   r   r   r   r   r[   r   r   r   setterr   r   __static_attributes____classdictcell____classcell__)r{   r"   s   @@r#   r   r      s    B- -0  "   	
 	
" "! !! !N NI. I.V  # # $1. .% %"% -1"% #	"%
  %"% !%"% )-"% ""% )*"% ""% #"% "%H- -

- 
-# # " " * *. .D% D% D%r&   r   ) r   
contextlibr   typingr   r   r   r   base_protocolr   client_exceptionsr	   r
   r   r   r   helpersr   r   r   r   r   httpr   r   http_exceptionsr   streamsr   r   r   r   rQ   r&   r#   <module>r      sV      . . '   9 0 ; ;N%lIe4F4T.U$V N%r&   