
    chD	                         S SK Jr  S SKJrJr  S SKJrJrJrJ	r	  S SK
r
SSKJr  SSKJr  SSKJr   " S	 S
5      r\S\
R$                  S\S\S\S\\   4
S j5       r\S\
R*                  S\S\S\S\\   4
S j5       rg)    )AsyncGenerator)asynccontextmanagercontextmanager)AnyAsyncIteratorIteratorcastN   )
SSEDecoder)SSEError)ServerSentEventc                       \ rS rSrS\R
                  SS4S jrSS jr\S\R
                  4S j5       r	S\
\   4S jrS\\S4   4S	 jrS
rg)EventSource   responsereturnNc                     Xl         g N	_response)selfr   s     F/var/www/html/shao/venv/lib/python3.13/site-packages/httpx_sse/_api.py__init__EventSource.__init__   s    !    c                     U R                   R                  R                  SS5      R                  S5      S   nSU;  a  [	        SU< 35      eg )Nzcontent-type ;r   text/event-streamzJExpected response header Content-Type to contain 'text/event-stream', got )r   headersget	partitionr   )r   content_types     r   _check_content_typeEventSource._check_content_type   sZ    ~~--11."EOOPSTUVWl2#&(  3r   c                     U R                   $ r   r   )r   s    r   r   EventSource.response   s    ~~r   c              #      #    U R                  5         [        5       nU R                  R                  5        H.  nUR	                  S5      nUR                  U5      nUc  M*  Uv   M0     g 7fN
)r$   r   r   
iter_linesrstripdecode)r   decoderlinesses       r   iter_sseEventSource.iter_sse   sU       ",NN--/D;;t$D..&C		 0s   AA*!	A*c                  #    U R                  5         [        5       n[        [        [        S 4   U R
                  R                  5       5      n U  S h  vN nUR                  S5      nUR                  U5      nUc  M0  U7v   M7   N2
 UR                  5       I S h  vN    g ! UR                  5       I S h  vN    f = f7fr)   )
r$   r   r	   r   strr   aiter_linesr,   r-   aclose)r   r.   linesr/   r0   s        r   	aiter_sseEventSource.aiter_sse%   s       ",^CI.0J0J0LM	!# d{{4(nnT*?I	e ,,.  %,,.  s`   ACB% B
BB
$B% B% B

B% CB!C%C 9B<:C  Cr   )r   N)__name__
__module____qualname____firstlineno__httpxResponser   r$   propertyr   r   r   r1   r   r8   __static_attributes__ r   r   r   r      sd    " "D " %..  (?3 !0E!F !r   r   clientmethodurlkwargsr   c              +      #    UR                  S0 5      nSUS'   SUS'   U R                  " X4SU0UD6 n[        U5      v   S S S 5        g ! , (       d  f       g = f7fNr    r   Acceptzno-storezCache-Controlpopstreamr   rC   rD   rE   rF   r    r   s         r   connect_sserN   3   sY      jjB'G+GH)GO	v	>G	>v	>((## 
?	>	>s   2AA	A
AAc                   #    UR                  S0 5      nSUS'   SUS'   U R                  " X4SU0UD6 IS h  vN n[        U5      7v   S S S 5      IS h  vN   g  N# N! , IS h  vN  (       d  f       g = f7frH   rJ   rM   s         r   aconnect_sserP   ?   sf      jjB'G+GH)GO}}VD'DVDD(## EDDDDDsD   6A:AA:A A:AA:A: A7&A)'A73A:)collections.abcr   
contextlibr   r   typingr   r   r   r	   r>   	_decodersr   _exceptionsr   _modelsr   r   Clientr4   rN   AsyncClientrP   rB   r   r   <module>rY      s    * : 5 5  ! ! $$! $!N $LL$"%$,/$;>$k$ $ $$$ 
$ 	$
 ;$ $r   