
    hjQ%                     l   d Z ddlZddlZddlmZmZ ddlmZmZm	Z	m
Z
mZmZmZmZmZ ddlZ ed          Z G d de	e                   Z G d d	e	e                   Ze G d
 d                      Zg dZ ed eD                       ZdZ	 	 ddej        deegef         dee         dedeedf         f
dZ	 	 ddej        deegef         dee         dedeeddf         f
dZdddddedeegef         dee         dee         dedeee         eee         f         fdZde dede!fdZ"dS ) zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.    N)	dataclassasdict)	AnyCallableGenericListTypeVarOptional	GeneratorAsyncGeneratorTupleTc                       e Zd ZU ee         ed<   ej        ed<   ee	ddf         ed<   e
ed<   	 	 	 ddej        deege	f         dee         dee         d	e
f
d
Zd Zd Zd Zd Zd ZdS )Stream
client_refresponseN	generator_closedTdecodersentineldata_requiredc                 `    || _         t          ||||          | _        || _        d| _        d S N)r   F)r   stream_eventsr   r   r   selfr   r   r   r   r   s         k/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/google/genai/_gaos/utils/eventstreaming.py__init__zStream.__init__.   s>     !&gx}
 
 
 %    c                     | S N r   s    r   __iter__zStream.__iter__=       r   c                 F    | j         rt          t          | j                  S r!   )r   StopIterationnextr   r#   s    r   __next__zStream.__next__@   s"    < 	 DN###r   c                     | S r!   r"   r#   s    r   	__enter__zStream.__enter__E   r%   r   c                 .    |                                   d S r!   closer   exc_typeexc_valexc_tbs       r   __exit__zStream.__exit__H   s    

r   c                 F    d| _         | j                                         d S NT)r   r   r.   r#   s    r   r.   zStream.closeK   s#    r   NNT)__name__
__module____qualname__r
   object__annotations__httpxResponser   r   boolr   strr   r$   r)   r+   r3   r.   r"   r   r   r   r   &   s             nD$''''MMM #''+" . 3%(# 3-	
 V$      $ $ $
        r   r   c                       e Zd ZU ee         ed<   ej        ed<   ee	df         ed<   e
ed<   	 	 	 ddej        deege	f         dee         dee         d	e
f
d
Zd Zd Zd Zd Zd ZdS )AsyncStreamr   r   Nr   r   Tr   r   r   c                 `    || _         t          ||||          | _        || _        d| _        d S r   )r   stream_events_asyncr   r   r   r   s         r   r   zAsyncStream.__init__X   s>     !,gx}
 
 
 %r   c                     | S r!   r"   r#   s    r   	__aiter__zAsyncStream.__aiter__g   r%   r   c                 `   K   | j         rt          | j                                         d {V S r!   )r   StopAsyncIterationr   	__anext__r#   s    r   rH   zAsyncStream.__anext__j   s<      < 	%$$^--/////////r   c                 
   K   | S r!   r"   r#   s    r   
__aenter__zAsyncStream.__aenter__o   s      r   c                 >   K   |                                   d {V  d S r!   r-   r/   s       r   	__aexit__zAsyncStream.__aexit__r   s,      jjllr   c                 V   K   d| _         | j                                         d {V  d S r5   )r   r   acloser#   s    r   r.   zAsyncStream.closeu   s9      m""$$$$$$$$$$$r   r6   )r7   r8   r9   r
   r:   r;   r<   r=   r   r   r>   r   r?   r   rE   rH   rJ   rL   r.   r"   r   r   rA   rA   P   s
             nag&&&&MMM #''+" . 3%(# 3-	
 V$      0 0 0
    % % % % %r   rA   c                   l    e Zd ZU dZee         ed<   dZee         ed<   dZe	ed<   dZ
ee         ed<   dS )ServerEventNideventdataretry)r7   r8   r9   rQ   r
   r?   r;   rR   rS   r   rT   intr"   r   r   rP   rP   z   s^         BE8C=D#E8C=r   rP   )s   

s   
s   

s   
s   

s   s   
s   

c              #   4   K   | ]}t          |          V  d S r!   )len).0bs     r   	<genexpr>rZ      s(      ::!s1vv::::::r   s   ﻿Tr   r   r   r   returnc           	       K   	 t                      }d}d }|                                 2 3 d {V }t          |          dk    r6|                    t                    r|t          t                    d          }t          |          }||z  }t          ||t          z
  dz             }	t          |	t          |                    D ]}
||
|
dz            }d }|dv rt          D ]}t          |
||          }| n|7|||
         }|
t          |          z   }t          |||||          \  }}}||W V  |r  |                                  d {V  d S |dk    r||d          }d}C6 t          |||||          \  }}}||W V  |                                  d {V  d S # |                                  d {V  w xY wNr      )      
)rawr   r   event_idr   )	bytearrayaiter_bytesrW   
startswithUTF8_BOMmaxMAX_BOUNDARY_LENrangeMESSAGE_BOUNDARIES_peek_sequence_parse_eventrN   r   r   r   r   bufferpositionrb   chunkold_lensearch_starticharseqboundaryblockrR   discard_s                     r   rC   rC      s{     1 "&#//11 !	 !	 !	 !	 !	 !	 !	%6{{aE$4$4X$>$>c(mmoo.&kkGeOFx3C)Ca)GHHL<V55  a!a%i('+>))$6 " ",QAA?!E +;xz*s3xx<+7#%%"/, , ,(w $KKKK F  oo# !||		*C 2F )'
 
 
w KKKKoohoos   &F) E-DF) 5F) )Gc           	   #   ^  K   	 t                      }d}d }|                                 D ]6}t          |          dk    r6|                    t                    r|t          t                    d          }t          |          }||z  }t          ||t          z
  dz             }	t          |	t          |                    D ]}
||
|
dz            }d }|dv rt          D ]}t          |
||          }| n|7|||
         }|
t          |          z   }t          |||||          \  }}}||V  |r  |                                  d S |dk    r||d          }d}8t          |||||          \  }}}||V  |                                  d S # |                                  w xY wr]   )rc   
iter_bytesrW   re   rf   rg   rh   ri   rj   rk   rl   r.   rm   s                     r   r   r      s     1"&((** !	 !	E6{{aE$4$4X$>$>c(mmoo.&kkGeOFx3C)Ca)GHHL<V55  a!a%i('+>))$6 " ",QAA?!E +;xz*s3xx<+7#%%"/, , ,(w $KKK F  	# !||		*('
 
 
w KKKs   D3F 3F F,)r   rb   r   ra   rb   c                    |                                  }t          j        d|          }d}t                      }g }	|D ]}
|
s|
                    d          }|dk    r!|
}d}|dk    rT|
d|         }|t          |
          dz
  k     r|
|dz   d          nd}t          |          r|d         dk    r
|dd          }|dk    r
||_        d	}|d
k    r|	                    |           d	}|dk    r	d	}d|vr|}|dk    r*|                                rt          |          |_
        d	}||_        t          |	          d                    |	          }|rr||k    rd d	|fS s	|r|rd d|fS r7	 t          j        |          |_        n# t          j        $ r
 ||_        Y nw xY wd }|rJfdt%          |                                          D             } |t          j        |                    }|d|fS )Nz\r?\n|\rF:r    r^    rR   TrS   rQ    rT   
c                 0    i | ]\  }}||dk    ||S )NrS   r"   )rX   kvhas_datas      r   
<dictcomp>z _parse_event.<locals>.<dictcomp>D  s8     
 
 
1}f q!,r   )decoderesplitrP   findrW   rR   appendisdigitrU   rT   rQ   r>   joinjsonloadsrS   JSONDecodeErrorr   itemsdumps)ra   r   r   rb   r   rw   linespublishrR   
data_partslinedelimfieldvaluerS   outout_dictr   s                    @r   rl   rl     s    JJLLEH[%((EGMMEJ   			#A::1995ME).TQ)>)>D%%BE5zz "eAh#ooabb	GEKGGf__e$$$GGd]]GU"" g}} )!%jjGEHJH99Z  D $H $!1!1T8##  % %M %UH$$ 	D))EJJ# 	 	 	EJJJ	 C ,
 
 
 
u++--
 
 

 gdj**++xs   4F F'&F'ro   rn   sequencec                     t          |          t          |          | z
  k    rd S t          |          D ]\  }}|| |z            |k    r d S |S r!   )rW   	enumerate)ro   rn   r   rs   ru   s        r   rk   rk   N  se    
8}}Fh.//tH%%  3(Q,3&&44 ' Or   r5   )#__doc__r   r   dataclassesr   r   typingr   r   r   r   r	   r
   r   r   r   r<   r   r   rA   rP   rj   rg   rh   rf   r=   r?   r>   rC   r   rc   rl   rU   bytesrk   r"   r   r   <module>r      s)  " H G 				  ) ) ) ) ) ) ) )
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 GCLL' ' ' ' 'WQZ ' ' 'T'% '% '% '% '%'!* '% '% '%T                	 	 	  3::'9:::::  #	7  7 n7 seQh7  sm7  	7 
 AtG7  7  7  7 z #	7 7n7seQh7 sm7 	7
 q$}7 7 7 7| #"F  F  F 	F  seQhF  sm	F 
 smF  F  8A;hsm+,F  F  F  F RS ) u      r   