+
    TŎir                        ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	H
t
 ^ RIH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 ^RIHtHt ^RIHt ^R	I H!t! ^R
I"H#t#H$t$H%t%H&t&H't'H(t(H)t)H*t*H+t+H,t, ^RIH-t-H.t.H/t/ ^RIH0t0 ^RI1H2t2H3t3 ] U u/ uF  q Ph                  V Pj                  bK  	  up t6Rt7R t8]'       d   ^RI9H:t: ]];]3,          t<M]P<                  P(                  t< ! R R]Pz                  4      t>]> Uu/ uF  qPh                  VbK  	  upt? ! R R]<]&4      t@ ! R R]@4      tA]*3RRRRR^RRRRRRR]P                  /R R llltCR# u up i u upi )!    N)Executor)
HTTPStatusSimpleCookie)TYPE_CHECKINGAnyDictIteratorMutableMappingOptionalUnioncast)CIMultiDictistr)hdrspayloadAbstractStreamWriter)ZLibCompressor)
ETAG_ANYQUOTED_ETAG_REETagHeadersMixinmust_be_empty_bodyparse_http_daterfc822_formatted_timesentinelshould_remove_content_lengthvalidate_etag_value)SERVER_SOFTWAREHttpVersion10HttpVersion11)Payload)JSONEncoderLooseHeadersContentCodingStreamResponseResponse)BaseRequestc                   "    ] tR t^;tRtRtRtRtR# )r&   deflategzipidentity N)__name__
__module____qualname____firstlineno__r+   r,   r-   __static_attributes__r.       c/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/web_response.pyr&   r&   ;   s    
 GDHr4   c                     a a ] tR t^Lt oRtRtRtRtRtRt	Rt
RtRtRtRt^ tRtRtR^RRRRRR/V3R lR	 l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4       t]V3R lR l4       t]V3R lR l4       tRtV3R lR lltV3R lR lt]V3R lR l4       tV3R lR lt]V3R lR l4       t]V3R  lR! l4       tRtV3R" lR# llt RuV3R$ lR% llt!]V3R& lR' l4       t"]V3R( lR) l4       t#R*RR+RR,RR-R.R/RR0RR1RR2RR3R/	V3R4 lR5 llt$R+RR-R.R/RR0RR2R/V3R6 lR7 llt%]V3R8 lV 3R9 ll4       t&]&PN                  V3R: lR; l4       t&]V3R< lV 3R= ll4       t(](PN                  V3R> lR? l4       t(]V3R@ lV 3RA ll4       t)])PN                  V3RB lRC l4       t)]V3RD lRE l4       t*]*PN                  V3RF lRG l4       t*]V3RH lRI l4       t+]+PN                  V3RJ lRK l4       t+],PZ                  3V3RL lRM llt.V3RN lRO lt/V3RP lRQ lt0V3RR lRS lt1V3RT lRU lt2V3RV lRW lt3V3RX lRY lt4V3RZ lR[ lt5V3R\ lR] lt6RvV3R^ lR_ llt7V3R` lRa lt8V3Rb lRc lt9V3Rd lRe lt:V3Rf lRg lt;V3Rh lRi lt<V3Rj lRk lt=V3Rl lRm lt>V3Rn lRo lt?V3Rp lRq lt@V3Rr ltARstBVtCV ;tD# )wr'   TNFstatusreasonheaders_real_headersc          
      v   < V ^8  d   QhRS[ RS[S[,          RS[S[,          RS[S[S[,          ,          RR/# )   r7   r8   r9   r:   returnN)intr   strr%   r   )format__classdict__s   "r5   __annotate__StreamResponse.__annotate__^   sR     ) ) ) 	)
 ,')  C 01) 
)r4   c                   / V n         Ve   W@n        M$Ve   \        V4      V n        M\        4       V n        V P                  W4       R# )a  Initialize a new stream response object.

_real_headers is an internal parameter used to pass a pre-populated
headers object. It is used by the `Response` class to avoid copying
the headers when creating a new response object. It is not intended
to be used by external code.
N)_state_headersr   _set_status)selfr7   r8   r9   r:   s   &$$$$r5   __init__StreamResponse.__init__^   s?     ')$)M .9'.BDM'MDM(r4   c                    < V ^8  d   QhRS[ /# r<   r=   bool)r@   rA   s   "r5   rB   rC   y   s     B B$ Br4   c                F    V P                   ;'       g    V P                  R J# N)	_eof_sent_payload_writerrH   s   &r5   preparedStreamResponse.preparedx   s    ~~AA!5!5T!AAr4   c                   < V ^8  d   QhRR/# )r<   r=   zOptional[asyncio.Task[None]]r.   )r@   rA   s   "r5   rB   rC   }   s      4 r4   c                V    V P                   '       d   V P                   P                  # R # rP   )_reqtaskrS   s   &r5   rY   StreamResponse.task|   s    99999>>!r4   c                    < V ^8  d   QhRS[ /# rL   r>   )r@   rA   s   "r5   rB   rC             r4   c                    V P                   # rP   )_statusrS   s   &r5   r7   StreamResponse.status       ||r4   c                    < V ^8  d   QhRS[ /# rL   rM   )r@   rA   s   "r5   rB   rC      s       r4   c                    V P                   # rP   )_chunkedrS   s   &r5   chunkedStreamResponse.chunked       }}r4   c                    < V ^8  d   QhRS[ /# rL   rM   )r@   rA   s   "r5   rB   rC      s     ! !T !r4   c                    V P                   # rP   )_compressionrS   s   &r5   compressionStreamResponse.compression          r4   c                    < V ^8  d   QhRS[ /# rL   r?   )r@   rA   s   "r5   rB   rC      r]   r4   c                    V P                   # rP   )_reasonrS   s   &r5   r8   StreamResponse.reason   ra   r4   c                :   < V ^8  d   QhRS[ RS[S[,          RR/# r<   r7   r8   r=   Nr>   r   r?   )r@   rA   s   "r5   rB   rC      s-     ) )) ) 
	)r4   c                Z    V P                   '       d   Q R 4       hV P                  W4       R# )zGCannot change the response status code after the headers have been sentN)rT   rG   rH   r7   r8   s   &&&r5   
set_statusStreamResponse.set_status   s-     	UT	U(r4   c                :   < V ^8  d   QhRS[ RS[S[,          RR/# rt   ru   )r@   rA   s   "r5   rB   rC      s&      # x}  r4   c                    \        V4      V n        Vf"   \        P                  V P                  R4      pMRV9   d   \	        R4      hW n        R # )N 
zReason cannot contain \n)r>   r_   REASON_PHRASESget
ValueErrorrq   rw   s   &&&r5   rG   StreamResponse._set_status   s@    6{>#''b9FV^899r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   )r   rN   )r@   rA   s   "r5   rB   rC      s        HTN  r4   c                    V P                   # rP   _keep_aliverS   s   &r5   
keep_aliveStreamResponse.keep_alive   s    r4   c                   < V ^8  d   QhRR/# r<   r=   Nr.   )r@   rA   s   "r5   rB   rC      s     ! !T !r4   c                    R V n         R# )FNr   rS   s   &r5   force_closeStreamResponse.force_close   s
     r4   c                    < V ^8  d   QhRS[ /# rL   r\   )r@   rA   s   "r5   rB   rC      s     ! !S !r4   c                    V P                   # rP   )_body_lengthrS   s   &r5   body_lengthStreamResponse.body_length   rm   r4   c                    < V ^8  d   QhRS[ /# rL   r\   )r@   rA   s   "r5   rB   rC      s     0 0s 0r4   c                    \         P                  ! R \        4       V P                  '       g   Q hV P                  P                  # )zoutput_length is deprecated)warningswarnDeprecationWarningrR   buffer_sizerS   s   &r5   output_lengthStreamResponse.output_length   s6    35GH#######///r4   c                4   < V ^8  d   QhRS[ S[,          RR/# )r<   
chunk_sizer=   Nr   r>   )r@   rA   s   "r5   rB   rC      s      (3- 4 r4   c                    \         P                  V P                  9   d   \        R4      hVe   \        P
                  ! R\        4       RV n        R# )z,Enables automatic chunked transfer encoding.z>You can't enable chunked encoding when a content length is setNzChunk size is deprecated #1615T)r   CONTENT_LENGTHrF   RuntimeErrorr   r   r   rd   )rH   r   s   &&r5   enable_chunked_encoding&StreamResponse.enable_chunked_encoding   sC    $--/P  !MM:<NOr4   c                `   < V ^8  d   QhRS[ S[S[S[3,          ,          RS[ S[,          RR/# )r<   forcestrategyr=   N)r   r   rN   r&   r>   )r@   rA   s   "r5   rB   rC      s<     . .dM123. 3-. 
	.r4   c                "   \        V\        4      '       dE   V'       d   \        P                  M\        P                  p\
        P                  ! R\        4       M!Ve   \        V\        4      '       g   Q R4       hRV n        Wn	        W n
        R# )z&Enables response compression encoding.z+Using boolean for force is deprecated #3318Nz1force should one of None, bool or ContentEncodingT)
isinstancerN   r&   r+   r-   r   r   r   rj   _compression_force_compression_strategy)rH   r   r   s   &&&r5   enable_compression!StreamResponse.enable_compression   s|     eT""-2M))8N8NEMM=?Q }  CBC  !"'%-"r4   c                   < V ^8  d   QhRR/# )r<   r=   zCIMultiDict[str]r.   )r@   rA   s   "r5   rB   rC      s      + r4   c                    V P                   # rP   )rF   rS   s   &r5   r9   StreamResponse.headers   rg   r4   c                    < V ^8  d   QhRS[ /# rL   r   )r@   rA   s   "r5   rB   rC      s       r4   c                T    V P                   f   \        4       V n         V P                   # rP   )_cookiesr   rS   s   &r5   cookiesStreamResponse.cookies   s    == (NDM}}r4   expiresdomainmax_agepath/securehttponlyversionsamesitepartitionedc                   < V ^8  d   QhRS[ RS[ RS[S[ ,          RS[S[ ,          RS[S[S[S[ 3,          ,          RS[ RS[S[,          RS[S[,          R	S[S[ ,          R
S[S[ ,          RS[S[,          RR/# )r<   namevaluer   r   r   r   r   r   r   r   r   r=   N)r?   r   r   r>   rN   )r@   rA   s   "r5   rB   rC      s     3+ 3+3+ 3+
 #3+ 3+ %S/*3+ 3+ 3+ 4.3+ #3+ 3-3+ d^3+ 
3+r4   c       	        l   V P                   f   \        4       V n         W P                   V&   V P                   V,          pVe   W<R&   MVP                  R4      R8X  d   VR Ve   WLR&   Ve   \        V4      VR&   M
RV9   d   VR WlR&   Ve   W|R&   Ve   WR&   V	e   WR	&   V
e   WR
&   Ve   WR&   R# R# )zSet or update response cookie.

Sets new cookie or updates existent with new value.
Also updates only those params which are not None.
Nr   Thu, 01 Jan 1970 00:00:00 GMTr   zmax-ager   r   r   r   r   r   )r   r   r   r?   )rH   r   r   r   r   r   r   r   r   r   r   r   cs   &&&$$$$$$$$$ r5   
set_cookieStreamResponse.set_cookie   s    ( == (NDM#dMM$"iLUU9!@@) hKw<AiL!^)&	 hK$jM"iL$jM"*m #r4   c                   < V ^8  d   QhRS[ RS[S[ ,          RS[ RS[S[,          RS[S[,          RS[S[ ,          RR/# )	r<   r   r   r   r   r   r   r=   N)r?   r   rN   )r@   rA   s   "r5   rB   rC     sa     
 

 	

 
 
 4.
 3-
 

r4   c                   V P                   e   V P                   P                  VR4       V P                  VR^ RVVVVVR7	       R# )z2Delete cookie.

Creates new empty expired cookie.
Nr|   r   )r   r   r   r   r   r   r   )r   popr   )rH   r   r   r   r   r   r   s   &&$$$$$r5   
del_cookieStreamResponse.del_cookie  sN     ==$MMdD)3 	 
	
r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   r   )r@   rA   s   "r5   rB   rC   2  s     & & &r4   c                   < \         SV `  # rP   )supercontent_lengthrH   	__class__s   &r5   r   StreamResponse.content_length1  s     w%%r4   c                4   < V ^8  d   QhRS[ S[,          RR/# r<   r   r=   Nr   )r@   rA   s   "r5   rB   rC   7  s     	9 	9HSM 	9d 	9r4   c                   VeQ   \        V4      pV P                  '       d   \        R4      h\        V4      V P                  \
        P                  &   R # V P                  P                  \
        P                  R 4       R # )Nz<You can't set content length when chunked encoding is enable)r>   rd   r   r?   rF   r   r   r   rH   r   s   &&r5   r   r   6  s^    JE}}}"R  25UDMM$--.MMd1148r4   c                    < V ^8  d   QhRS[ /# rL   ro   )r@   rA   s   "r5   rB   rC   C  s     $ $c $r4   c                   < \         SV `  # rP   )r   content_typer   s   &r5   r   StreamResponse.content_typeB  s     w##r4   c                $   < V ^8  d   QhRS[ RR/# r   ro   )r@   rA   s   "r5   rB   rC   H  s     - -# -$ -r4   c                ^    V P                    \        V4      V n        V P                  4        R # rP   )r   r?   _content_type_generate_content_type_headerr   s   &&r5   r   r   G  s#     Z**,r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   r   r?   )r@   rA   s   "r5   rB   rC   N  s      # r4   c                   < \         SV `  # rP   )r   charsetr   s   &r5   r   StreamResponse.charsetM  s     wr4   c                4   < V ^8  d   QhRS[ S[,          RR/# r   r   )r@   rA   s   "r5   rB   rC   S  s     - -Xc] -t -r4   c                   V P                   pVR 8X  d   \        R4      hV P                  f   Q hVf   V P                  P                  RR4       M&\	        V4      P                  4       V P                  R&   V P                  4        R# )application/octet-streamzYSetting charset for application/octet-stream doesn't make sense, setup content_type firstNr   )r   r   _content_dictr   r?   lowerr   )rH   r   ctypes   && r5   r   r   R  s    !!..?  !!---=""9d3,/J,<,<,>Dy)**,r4   c                D   < V ^8  d   QhRS[ S[P                  ,          /# rL   )r   datetime)r@   rA   s   "r5   rB   rC   b  s"     F Fx(9(9: Fr4   c                f    \        V P                  P                  \        P                  4      4      # )zeThe value of Last-Modified HTTP header, or None.

This header is represented as a `datetime` object.
)r   rF   r   r   LAST_MODIFIEDrS   s   &r5   last_modifiedStreamResponse.last_modifieda  s$     t}}001C1CDEEr4   c                f   < V ^8  d   QhRS[ S[S[S[S[P                  S[3,          ,          RR/# r   )r   r   r>   floatr   r?   )r@   rA   s   "r5   rB   rC   j  s6     ! !eC0A0A3$FGH!	!r4   c                   Vf-   V P                   P                  \        P                  R 4       R # \	        V\
        \        34      '       d]   \        P                  ! R\        P                  ! \        P                  ! V4      4      4      V P                   \        P                  &   R # \	        V\        P                  4      '       dC   \        P                  ! RVP                  4       4      V P                   \        P                  &   R # \	        V\        4      '       d   WP                   \        P                  &   R # R\        V4      P                    2p\#        V4      h)Nz%a, %d %b %Y %H:%M:%S GMTz$Unsupported type for last_modified: )rF   r   r   r   r   r>   r   timestrftimegmtimemathceilr   utctimetupler?   typer/   	TypeError)rH   r   msgs   && r5   r   r   i  s     =MMd00$7U|,,04+T[[59I-J1DMM$,,- x001104+U-?-?-A1DMM$,,- s##05MM$,,-8e9M9M8NOCC. r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   )r   r   )r@   rA   s   "r5   rB   rC   ~  s     
 
htn 
r4   c                2   V P                   P                  \        P                  4      pV'       g   R # V\        8X  d   \        \        R7      # \        P                  ! V4      pV'       g   R # VP                  ^^4      w  r4\        \        V4      VR7      # )N)r   )is_weakr   )
rF   r   r   ETAGr   r   r   	fullmatchgrouprN   )rH   quoted_valuematchr   r   s   &    r5   etagStreamResponse.etag}  sr    }}((3X%h''((6Q*M
 	
r4   c                J   < V ^8  d   QhRS[ S[S[S[3,          ,          RR/# r   )r   r   r   r?   )r@   rA   s   "r5   rB   rC     s)      (5s#34  r4   c                .   Vf-   V P                   P                  \        P                  R 4       R # \	        V\
        4      '       d   V\        8X  g,   \	        V\        4      '       d9   VP                  \        8X  d$   \        V P                   \        P                  &   R # \	        V\
        4      '       d/   \        V4       RV R2V P                   \        P                  &   R # \	        V\        4      '       d   \	        VP                  \
        4      '       df   \        VP                  4       VP                  '       d   RVP                   R2MRVP                   R2pW P                   \        P                  &   R # \        R\        V4       R24      h)N"zW/"zUnsupported etag type: z . etag must be str, ETag or None)rF   r   r   r   r   r?   r   r   r   r   r   r   r   )rH   r   	hdr_values   && r5   r  r    s   =MMdii.$$():ud##x(?'/DMM$))$s##&)*5'|DMM$))$t$$EKK)E)E,05#ekk]!,Qu{{mSTCUI'0MM$))$)$u+ 71 2 r4   c                $   < V ^8  d   QhRS[ RR/# )r<   CONTENT_TYPEr=   N)r   )r@   rA   s   "r5   rB   rC     s     
, 
, 
,	
,r4   c                    V P                   f   Q hV P                  f   Q hRP                  R V P                   P                  4        4       4      pV'       d   V P                  R,           V,           pMV P                  pW0P                  V&   R # )Nz; c              3   4   "   T F  w  rV R V 2x  K  	  R# 5i)=Nr.   ).0kvs   &  r5   	<genexpr>?StreamResponse._generate_content_type_header.<locals>.<genexpr>  s     M2L$!aS!:2Ls   )r   r   joinitemsrF   )rH   r	  paramsr   s   &&  r5   r   ,StreamResponse._generate_content_type_header  sz     !!---!!---M$2D2D2J2J2LMM&&-6E&&E&+l#r4   c                $   < V ^8  d   QhRS[ RR/# r<   codingr=   Nr&   )r@   rA   s   "r5   rB   rC     s     
8 
8- 
8D 
8r4   c                \  "   V\         P                  J d   R # V P                  f   Q hVP                  V P                  \
        P                  &   V P                  P                  VP                  V P                  4       V P                  P                  \
        P                  R 4       R # 5irP   )r&   r-   rR   r   rF   r   CONTENT_ENCODINGr   r   popallr   )rH   r  s   &&r5   _do_start_compression$StreamResponse._do_start_compression  s     ]+++##////5||d++,//LL$44	

 	T00$7s   B*B,c                "   < V ^8  d   QhRRRR/# )r<   requestr)   r=   Nr.   )r@   rA   s   "r5   rB   rC     s     
 
 
$ 
r4   c                r  "   V P                   '       d&   V P                  V P                   4      G R j  xL
  R # VP                  P                  \        P
                  R4      P                  4       p\        P                  4        F'  w  r4W29   g   K  V P                  V4      G R j  xL
   R # 	  R #  L L5i)Nr|   )	r   r  r9   r   r   ACCEPT_ENCODINGr   CONTENT_CODINGSr  )rH   r   accept_encodingr   r  s   &&   r5   _start_compression!StreamResponse._start_compression  s     """,,T-D-DEEE "//--d.B.BBGMMO,224ME'00888 5 F 9s(   1B7B3AB7B7'B5(B75B7c                4   < V ^8  d   QhRRRS[ S[,          /# r<   r   r)   r=   )r   r   )r@   rA   s   "r5   rB   rC     s!     * *] *x@T7U *r4   c                   "   V P                   '       d   R # V P                  e   V P                  # \        VP                  V P                  4      V n        V P                  V4      G R j  xL
 #  L5irP   )rQ   rR   r   methodr7   _must_be_empty_body_start)rH   r   s   &&r5   prepareStreamResponse.prepare  sU     >>>+'''#5gnndkk#R [[))))s   A(A1*A/+A1c                $   < V ^8  d   QhRRRS[ /# r(  r   )r@   rA   s   "r5   rB   rC     s      M 6J r4   c                   "   Wn         VP                  ;q n        V P                  4       G R j  xL
  VP                  V 4      G R j  xL
  V P	                  4       G R j  xL
  V#  L7 L  L
5irP   )rX   rR   _prepare_headers_prepare_hook_write_headers)rH   r   writers   && r5   r,  StreamResponse._start  sc     	(/(?(??%##%%%##D)))!!###	 	&)#s3   ,A,A&A,A(A,A* A,(A,*A,c                   < V ^8  d   QhRR/# r   r.   )r@   rA   s   "r5   rB   rC     s     ?3 ?3 ?3r4   c                  "   V P                   pVf   Q hV P                  pVf   Q hV P                  pVf   VP                  pW0n        VP                  pV P
                  pV P                  '       d[   V P                  P                  4        F<  pVP                  RR7      R,          pVP                  \        P                  V4       K>  	  V P                  '       d   V P                  V4      G R j  xL
  V P                  '       df   V\        8w  d%   \!        RP#                  VP                  4      4      hV P$                  '       g$   VP'                  4        RV\        P(                  &   MV P*                  '       du   V P,                  Vn        VP.                  fV   V\        8  d7   V P$                  '       g$   VP'                  4        RV\        P(                  &   MV P$                  '       g   RpV P$                  '       dt   \        P0                  V9   d8   \3        VP4                  V P6                  4      '       d   V\        P0                   \        P(                  V9   d   V\        P(                   MOV P*                  '       d   VP.                  MV P,                  ^ 8w  d!   VP9                  \        P:                  R4       VP9                  \        P<                  \?        4       4       VP9                  \        P@                  \B        4       \        PD                  V9  dM   V'       d#   V\F        8X  d   RV\        PD                  &   R # R # V\        8X  d   R	V\        PD                  &   R # R # R #  EL5i)
Nr|   )header:   NNz@Using chunked encoding is forbidden for HTTP/{0.major}.{0.minor}re   Fr   z
keep-aliveclose)$rX   rR   r   r   r   rF   r   valuesoutputaddr   
SET_COOKIErj   r%  rd   r"   r   r@   r+  enable_chunkingTRANSFER_ENCODING_length_checkr   lengthr   r   r*  r7   
setdefaultr	  DATEr   SERVERr    
CONNECTIONr!   )rH   r   r4  r   r   r9   cookier   s   &       r5   r1  StreamResponse._prepare_headers  s    ))"""%%!!!%%
 ++J%//--===--..0R04DOOU3 1 ))'222===-'"3396'//3J  +++&&(2;../ //FM}}$m+333..0:C 6 67111!&J ###""g-2N3 3 D//0 %%0D223#111fmmt7J7JqPt002LM499&;&=>4;;8 ??')m+/;GDOO, ,M)+2( *	 *O 3sL   CM;M;3M84M;
A M;5M;;M;=5M;3M;BM;B%M;2AM;c                   < V ^8  d   QhRR/# r   r.   )r@   rA   s   "r5   rB   rC     s     " "d "r4   c                `  "   V P                   pVf   Q hV P                  pVf   Q hVP                  pRV^ ,           RV^,           RV P                   RV P                   2pVP                  W@P                  4      G R j  xL
  V P                  '       d   VP                  4        R # R #  L*5i)NzHTTP/. )	rX   rR   r   r_   rq   write_headersrF   _send_headers_immediatelysend_headers)rH   r   r4  r   status_lines   &    r5   r3  StreamResponse._write_headers  s     ))"""%%!!!//gaj\71:,a~Qt||nU"";>>>)))! * 	?s   A?B.B,B.B.c                >   < V ^8  d   QhRS[ S[S[S[3,          RR/# r<   datar=   N)r   bytes	bytearray
memoryview)r@   rA   s   "r5   rB   rC   &  s'     
/ 
/eY
&B C 
/ 
/r4   c                4  "   \        V\        \        \        34      '       g   Q R \	        V4      ,          4       hV P
                  '       d   \        R4      hV P                  f   \        R4      hV P                  P                  V4      G Rj  xL
  R#  L5i)#data argument must be byte-ish (%r)z%Cannot call write() after write_eof()Nz$Cannot call write() before prepare())	r   rU  rV  rW  r   rQ   r   rR   writerH   rT  s   &&r5   rZ  StreamResponse.write&  s     5)Z0
 
 	>04:=	> 
 >>>FGG'EFF""((...s   A
BABBBc                   < V ^8  d   QhRR/# r   r.   )r@   rA   s   "r5   rB   rC   2  s     + +T +r4   c                   "   V P                   '       d   Q R 4       hV P                  f   Q R4       h\        P                  ! R\        ^R7       V P                  P                  4       G Rj  xL
  R#  L5i)zEOF has already been sentNResponse has not been startedz2drain method is deprecated, use await resp.write())
stacklevel)rQ   rR   r   r   r   drainrS   s   &r5   ra  StreamResponse.drain2  sa     >>>>#>>!##/P1PP/@	

 ""((***s   A)A4+A2,A4c                $   < V ^8  d   QhRS[ RR/# rS  rU  )r@   rA   s   "r5   rB   rC   <  s     $ $E $D $r4   c                z  "   \        V\        \        \        34      '       g   Q R \	        V4      ,          4       hV P
                  '       d   R# V P                  f   Q R4       hV P                  P                  V4      G Rj  xL
  RV n        RV n        V P                  P                  V n
        RV n        R#  L65i)rY  Nr_  T)r   rU  rV  rW  r   rQ   rR   	write_eofrX   output_sizer   r[  s   &&r5   rf  StreamResponse.write_eof<  s     5)Z0
 
 	>04:=	> 
 >>>##/P1PP/"",,T222	 00<<#	 	3s   A
B;5B;B97B;c                    < V ^8  d   QhRS[ /# rL   ro   )r@   rA   s   "r5   rB   rC   L  s     C C# Cr4   c                *   V P                   '       d   R pMUV P                  '       dB   V P                  f   Q hV P                  P                   RV P                  P                   R2pMRpRV P
                  P                   RV P                   RV R2# )eofrL  znot prepared<>)rQ   rT   rX   r*  r   r   r/   r8   )rH   infos   & r5   __repr__StreamResponse.__repr__L  s~    >>>D]]]99(((ii&&'q(8:D!D4>>**+1T[[M4&BBr4   c                &   < V ^8  d   QhRS[ RS[/# )r<   keyr=   r?   r   )r@   rA   s   "r5   rB   rC   V  s        s  s  r4   c                (    V P                   V,          # rP   rE   rH   rr  s   &&r5   __getitem__StreamResponse.__getitem__V  s    {{3r4   c                *   < V ^8  d   QhRS[ RS[RR/# )r<   rr  r   r=   Nrs  )r@   rA   s   "r5   rB   rC   Y  s"     ! !s !3 !4 !r4   c                "    W P                   V&   R # rP   ru  )rH   rr  r   s   &&&r5   __setitem__StreamResponse.__setitem__Y  s     Cr4   c                $   < V ^8  d   QhRS[ RR/# )r<   rr  r=   Nro   )r@   rA   s   "r5   rB   rC   \  s      s t r4   c                     V P                   V R # rP   ru  rv  s   &&r5   __delitem__StreamResponse.__delitem__\  s    KKr4   c                    < V ^8  d   QhRS[ /# rL   r\   )r@   rA   s   "r5   rB   rC   _  s          r4   c                ,    \        V P                  4      # rP   )lenrE   rS   s   &r5   __len__StreamResponse.__len___  s    4;;r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   )r
   r?   )r@   rA   s   "r5   rB   rC   b  s     ! !(3- !r4   c                ,    \        V P                  4      # rP   )iterrE   rS   s   &r5   __iter__StreamResponse.__iter__b  s    DKK  r4   c                    < V ^8  d   QhRS[ /# rL   r\   )r@   rA   s   "r5   rB   rC   e  s      # r4   c                *    \        \        V 4      4      # rP   )hashidrS   s   &r5   __hash__StreamResponse.__hash__e  s    BtH~r4   c                &   < V ^8  d   QhRS[ RS[/# )r<   otherr=   )objectrN   )r@   rA   s   "r5   rB   rC   h  s      F t r4   c                    WJ # rP   r.   )rH   r  s   &&r5   __eq__StreamResponse.__eq__h  s
    }r4   c                    < V ^8  d   QhRS[ /# rL   rM   )r@   rA   s   "r5   rB   rC   k  s      $ r4   c                    R # )Tr.   rS   s   &r5   __bool__StreamResponse.__bool__k  s    r4   c                (  < V ^8  d   Qh/ S[ RS[S[S[3,          ;R&   S[S[,          ;R&   S[;R&   S[;R&   S[S[,          ;R&   S[S[,          ;R&   S[R,          ;R	&   S[S[,          ;R
&   S[;R&   S[S[,          ;R&   S[S[	,          ;R&   # )r<   N_bodyr   rd   rj   r   r   r)   rX   rR   rQ   r+  r   )
r   rU  rV  r#   r   rN   r>   r&   r   r   )r@   rA   s   "r5   rB   rC   L   s     ui011 
 $&      $C=/  !/6  =
!(  23:    "$.  |$+ r4   )r   rd   rj   r   r   r   r   rQ   rF   r   r+  rR   rq   rX   rE   r_   rP   )NNr4   )Er/   r0   r1   r2   rA  r  r   rd   rj   r   r   rX   rR   rQ   r+  r   r   rN  rI   propertyrT   rY   r7   re   rk   r8   rx   rG   r   r   r   r   r   r   r9   r   r   r   r   setterr   r   r   r  r   r	  r   r  r%  r-  r,  r1  r3  rZ  ra  rf  ro  rw  r{  r  r  r  r  r  r  __annotate_func__r3   __classdictcell____classcell__r   rA   s   @@r5   r'   r'   L   s     ME"&KHL+/26$(D6:OI*.L'+H $) ) !%	)
 +/) 59) )4 B B       ! !  ) )     ! ! ! ! 0 0
 . .*    
3+
 "&3+ !%3+ .23+ 3+ "&3+ $(3+ "&3+ #'3+ '+3+ 3+j
 !%	

 
 "&
 $(
 #'
 
: & & & 	9 	9 $ $ $ - -
    ^^- - F F ! !& 
 
 
[[ * $(#4#4
, 
,
8 
8
 
* * ?3 ?3B" "
/ 
/+ +$ $ C C   ! !    ! !     r4   c                     a a ] tR tRt oRtRtRRR^RRRRRRR	RR
RRRRR/	V3R lV 3R lllt]V3R lR l4       t]P                  V3R lR l4       t]V3R lR l4       t
]
P                  V3R lR l4       t
]V3R lR l4       t]P                  V3R lR l4       tR#V3R lV 3R llltV3R lV 3R lltV3R lV 3R  lltV3R! ltR"tVtV ;t# )$r(   io  NFbodyr7   r8   textr9   r   r   zlib_executor_sizezlib_executorc                   < V ^8  d   QhRS[ RS[RS[S[,          RS[S[,          RS[S[,          RS[S[,          RS[S[,          RS[S[,          R	S[S[,          R
R/
# )r<   r  r7   r8   r  r9   r   r   r  r  r=   N)r   r>   r   r?   r%   r   )r@   rA   s   "r5   rB   Response.__annotate__t  s     ?, ?, ?, 	?,
 ?, sm?, ,'?, sm?, #?, %SM?,  )?, 
?,r4   c       	          < Ve   Ve   \        R4      hVf   \        4       p
M\        V4      p
Ve   RV9   d   \        R4      hVe   \        P                  V
9   d   V'       g	   V'       d   \        R4      hM\	        V\
        4      '       g   \        R\        V4      ,          4      hVf   RpVf   RpVR,           V,           V
\        P                  &   VP                  V4      pR pMS\        P                  V
9   d   Vf   Ve   \        R4      hM*Ve'   Ve   VRV,           ,          pWj\        P                  &   \        SV `)  W#V
R	7       Ve   W@n        MWn        Wn        Wn        R # )
Nz&body and text are not allowed togetherr   z,charset must not be in content_type argumentzPpassing both Content-Type header and content_type or charset params is forbiddentext argument must be str (%r)
text/plainutf-8z
; charset=)r7   r8   r:   )r   r   r   r	  r   r?   r   r   encoder   rI   r  r  _zlib_executor_size_zlib_executor)rH   r  r7   r8   r  r9   r   r   r  r  real_headersr   s   &$$$$$$$$$ r5   rI   Response.__init__t  sk     0EFF?-8]L&w/L#	\(AKLL  L07$'  $+ "$,,#$DtDz$QRR'#/L?%G2>2MPW2WT../{{7+,.'7+> #  ,? %"w 66.:**+\RII#5 +r4   c                F   < V ^8  d   QhRS[ S[S[S[3,          ,          /# rL   )r   r   rU  r#   )r@   rA   s   "r5   rB   r    s"      huUG^45 r4   c                    V P                   # rP   )r  rS   s   &r5   r  Response.body  s    zzr4   c                $   < V ^8  d   QhRS[ RR/# )r<   r  r=   N)r   )r@   rA   s   "r5   rB   r    s     % % % %r4   c                &   Vf	   R V n         M\        V\        \        34      '       d   Wn         M \        P
                  P                  V4      ;V n         pT P                  p\        P                  T9  d   TP                  T\        P                  &   TP                  '       d0   TP                  P                  4        F  w  r4Y29  g   K  YBT&   K  	  R V n        R #   \        P                   d    \        R\        T4      ,          4      hi ; i)NzUnsupported body type %r)r  r   rU  rV  r   PAYLOAD_REGISTRYr   LookupErrorr   r   rF   r   r	  r   r9   r  _compressed_body)rH   r  r9   rr  r   s   &&   r5   r  r    s    <DJui011JJ$+$<$<$@$@$FF
T mmG   /-1->->))* |||"&,,"4"4"6JC)', #7 !% && J !;d4j!HIIJs   &C 1Dc                0   < V ^8  d   QhRS[ S[,          /# rL   r   )r@   rA   s   "r5   rB   r    s     : :hsm :r4   c                    V P                   f   R # V P                   P                  V P                  ;'       g    R4      # )Nr  )r  decoder   rS   s   &r5   r  Response.text  s2    :: zz  !8!899r4   c                $   < V ^8  d   QhRS[ RR/# )r<   r  r=   Nro   )r@   rA   s   "r5   rB   r    s     % % % %r4   c                   Ve.   \        V\        4      '       g   Q R\        V4      ,          4       hV P                  R8X  d   RV n        V P                  f   RV n        VP                  V P                  4      V n        R V n        R # )Nr  r   r  r  )r   r?   r   r   r   r  r  r  )rH   r  s   &&r5   r  r    sy    |z# 
  
 	9+d4j8	9 
  :: ,D<<"DL[[.
 $r4   c                0   < V ^8  d   QhRS[ S[,          /# rL   r   )r@   rA   s   "r5   rB   r    s       r4   c                   V P                   '       d   R # \        P                  V P                  9   d+   \	        V P                  \        P                  ,          4      # V P
                  e   \        V P
                  4      # \        V P                  \        4      '       d   R # V P                  e   \        V P                  4      # ^ # rP   )
rd   r   r   rF   r>   r  r  r   r  r#   rS   s   &r5   r   Response.content_length  s    ===$--/t}}T%8%89::  ,t,,--

G,,ZZ#tzz?"r4   c                4   < V ^8  d   QhRS[ S[,          RR/# r   r   )r@   rA   s   "r5   rB   r    s#     B BHSM Bd Br4   c                    \        R 4      h)z#Content length is set automatically)r   r   s   &&r5   r   r    s    @AAr4   c                $   < V ^8  d   QhRS[ RR/# rS  rd  )r@   rA   s   "r5   rB   r    s     7 7E 7D 7r4   c                  <"   V P                   '       d   R # V P                  f   V P                  pMV P                  pV'       d   Q RV: 24       hV P                  f   Q hV P                  f   Q hVe   V P
                  '       d   \        SV `  4       G R j  xL
  R # \        V P                  \        4      '       dh   V P                  P                  V P                  4      G R j  xL
  V P                  P                  4       G R j  xL
  \        SV `  4       G R j  xL
  R # \        SV `  \        \        V4      4      G R j  xL
  R #  L Lg LG L3 L5i)Nzdata arg is not supported, got )rQ   r  r  rX   rR   r+  r   rf  r   r#   rZ  r:  r   rU  )rH   rT  r  r   s   && r5   rf  Response.write_eof  s    >>>  (48JJD((DC:4(CCxyy$$$##///<4333'#%%%

G,,**""4#7#7888**""$$$'#%%%'#D$5666 &8$%6sh   AEA EEEAE(E)!E
EE E!&EEEEEEEc                $   < V ^8  d   QhRRRS[ /# r(  r   )r@   rA   s   "r5   rB   r    s     - -M -6J -r4   c                  <"   \         P                  V P                  9   dC   \        VP                  V P
                  4      '       d   V P                  \         P                   MV P                  '       g   \        V P                  \        4      '       dB   V P                  P                  ;pe'   \        V4      V P                  \         P                  &   MV P                  '       d   \        V P                  4      MRpVR8w  g1   V P
                  R8w  dF   VP                  \         P                  9  d'   \        V4      V P                  \         P                  &   \        SV `=  V4      G R j  xL
 #  L5i)N0i0  )r   r   rF   r   r*  r7   rd   r   r  r#   sizer?   r  METH_HEAD_ALLr   r,  )rH   r   r  body_lenr   s   &&  r5   r,  Response._start  s     $--/+GNNDKKHHMM$"5"56$**g.. JJOO+D89<TDMM$"5"56.2jjj3tzz?cs?KK3&7>>ASAS+S9<XDMM$"5"56W^G,,,,s    A3E77A2E7*BE70E51E7c                $   < V ^8  d   QhRS[ RR/# r  r  )r@   rA   s   "r5   rB   r  &  s     M M- MD Mr4   c                <  <"   V P                   '       g!   \        V P                  \        4      '       d   \        SV `  V4      G R j  xL
 # V\        P                  J d   R # \        VP                  V P                  V P                  R7      pV P                  f   Q hV P                  fL   \        V P                  4      \        8  d.   \        P                  ! R\        V P                  4       R24       VP!                  V P                  4      G R j  xL
 VP#                  4       ,           V n        VP                  V P&                  \(        P*                  &   \-        \        V P$                  4      4      V P&                  \(        P.                  &   R #  ELO L5i)N)encodingmax_sync_chunk_sizeexecutorz2Synchronous compression of large response bodies (z bytes) might block the async event loop. Consider providing a custom value to zlib_executor_size/zlib_executor response properties or disabling compression on it.)rd   r   r  r#   r   r  r&   r-   r   r   r  r  r  LARGE_BODY_SIZEr   r   compressflushr  rF   r   r  r?   r   )rH   r  
compressorr   s   && r5   r  Response._do_start_compression&  s5    ===Jtzz7;;6v>>>]+++ $\\ $ 8 8((


 zz%%%##+DJJ/0QMM

O$ %TT %%djj11J4D4D4FF 	 06||d++,-0T5J5J1K-Ld))*- ?& 2s&   AFF	CFFBFFc                6   < V ^8  d   Qh/ S[ S[,          ;R&   # )r<   r  )r   rU  )r@   rA   s   "r5   rB   r  o  s     uo, r4   )r  r  r  r  r  r   r   r  r  )r/   r0   r1   r2   r  rN  rI   r  r  r  r  r   rf  r,  r  r  r3   r  r  r  s   @@r5   r(   r(   o  s&    (, %?, ?, 	?,
 !%?, #?, +/?, '+?, "&?, -1?, -1?, ?,B   
[[% %2 : : 
[[% %  $ B B7 7&- -$M Mo  r4   r  r  r7   r8   r9   r   zapplication/jsondumpsc                    V ^8  d   QhR\         R\        \        ,          R\        \        ,          R\        R\        \        ,          R\        \
        ,          R\        R\        R	\        /	# )
r<   rT  r  r  r7   r8   r9   r   r  r=   )r   r   r?   rU  r>   r%   r$   r(   )r@   s   "r5   rB   rB   A  su      
 3- 5/	
  SM l#   r4   c          	      ~    V \         Jd$   V'       g	   V'       d   \        R 4      hV! V 4      p\        VVVVVVR7      # )z3only one of data, text, or body should be specified)r  r  r7   r8   r9   r   )r   r   r(   )rT  r  r  r7   r8   r9   r   r  s   &$$$$$$$r5   json_responser  A  sE     84RSS;D! r4   i   )r&   r'   r(   r  )Dasynciocollections.abccollectionsr   enumjsonr   r   r   concurrent.futuresr   httpr   http.cookiesr   typingr   r   r	   r
   r   r   r   r   	multidictr   r   r|   r   r   abcr   compression_utilsr   helpersr   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   typedefsr$   r%   r   phraser~   r  __all__web_requestr)   r?   	BaseClassEnumr&   r#  r'   r(   r  r  )http_statusr  s   00r5   <module>r     si           '  %	 	 	 (  % -   @ ?  /KUV:K##[%7%77:V
J (sCx(I..IDII  7DDmF<<'mD`Y `FOM~ OMf   !	
  ! '+ +  k W2 Es   EE