
    7Mg5                     X   d Z ddlZddlZddlmZmZmZmZmZm	Z	 ddl
Z
 ed      Z G d d      Zg dZ	 dde
j                  d	eegef   d
ee   deedf   fdZ	 dde
j                  d	eegef   d
ee   deeddf   fdZ	 dded	eegef   d
ee   de	ee   ef   fdZdededefdZy)zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.    N)CallableTypeVarOptional	GeneratorAsyncGeneratorTupleTc                   ^    e Zd ZU dZee   ed<   dZee   ed<   dZee   ed<   dZ	ee
   ed<   y)ServerEventNideventdataretry)__name__
__module____qualname__r   r   str__annotations__r   r   r   int     rE:\wamp.anq\www\apps\calme\nutritwin\resources\nutritwin\Lib\site-packages\mistralai_azure/utils/eventstreaming.pyr   r      s:    BE8C=D(3-E8C=r   r   )s   

s   

s   responsedecodersentinelreturnc                  K   t               }d}d}| j                         2 3 d {   }|r||z  }t        |t        |            D ]Z  }|||dz    }d }	|dv rt        D ]  }
t        |||
      }	|	 n |	0||| }|t        |	      z   }t        |||      \  }}|V| \ |dkD  s||d  }d}7 6 t        |||      \  }}|| y y wNr   F   )      
)	bytearrayaiter_bytesrangelenMESSAGE_BOUNDARIES_peek_sequence_parse_eventr   r   r   bufferpositiondiscardchunkicharseqboundaryblockr   s                r   stream_events_asyncr3      s    
 [FHG++- e %xV-A!a!e$D#'C~% 2H(FH=C !3 {8A&E3s8|H)%(CNE7  ." a<HI&FH7-: "&'8<NE7 s8   CB4B2B4AC1+CC*C2B44Cc              #     K   t               }d}d}| j                         D ]  }|r||z  }t        |t        |            D ]Y  }|||dz    }d }	|dv rt        D ]  }
t        |||
      }	|	 n |	0||| }|t        |	      z   }t        |||      \  }}|V| [ |dkD  s||d  }d} t        |||      \  }}|| y y wr   )r"   
iter_bytesr$   r%   r&   r'   r(   r)   s                r   stream_eventsr6   C   s    
 [FHG$$& %xV-A!a!e$D#'C~% 2H(FH=C !3 {8A&E3s8|H)%(CNE7  ." a<HI&FH7 ': "&'8<NE7 s   A(C++CC#!Crawc                 l   | j                         }t        j                  d|      }d}t               }d}|D ]  }|s|j	                  d      }	|	dk  r|d|	 }
|	t        |      dz
  k  r||	dz   d  nd}t        |      r|d   dk(  r|dd  }|
dk(  r
||_        d	}d|
d
k(  r||dz   z  }d	}t|
dk(  r
||_        d	}|
dk(  s|j                         rt        |      nd |_
        d	} |r	|| dk(  ry|r|d d }||_        |j                         xs |dk(  xs |dk(  xs |dk(  }|j                  d      xs$ |j                  d      xs |j                  d      }|s|r	 t        j                  |      |_        d }|r% |t        j"                  |j$                              }|dfS # t         $ r Y 8w xY w)Nz\r?\n|\rF :r   r    r   Tr   
r   r   )NTtruefalsenull{[")decoderesplitr   findr%   r   r   isdigitr   r   r   	isnumeric
startswithjsonloads	Exceptiondumps__dict__)r7   r   r   r2   linespublishr   r   linedelimfieldvaluedata_is_primitivedata_is_jsonouts                  r   r(   r(   m   s    JJLEHH[%(EGMED		#A:Qu%*SY]%:UQY[!u:%(c/!"IEGEKGf_EDL DGd]EHGg(-#e*TEKG1 4 DxjO+CRy
 NNSS$'/STV^ 	 OOC PDOOC$8PDOOC<P 	 !ZZ-
 Cdjj01:  s    F' '	F32F3r+   r*   sequencec                 |    t        |      t        |      | z
  kD  ry t        |      D ]  \  }}|| |z      |k7  s y  |S N)r%   	enumerate)r+   r*   rY   r.   r0   s        r   r'   r'      sH    
8}Fh./H%3(Q,3& & Or   r[   )__doc__rE   rK   typingr   r   r   r   r   r   httpxr	   r   r&   Responser   r3   r6   r"   boolr(   r   bytesr'   r   r   r   <module>rc      s.   G 	  P P CL     #'nn'seQh' sm' AtG	'Z #'nn'seQh' sm' q$}	'V LP:	:%seQh/:;CC=:
8A;:zS ) u r   