
    Ng5                        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dS )zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.    N)CallableTypeVarOptional	GeneratorAsyncGeneratorTupleTc                   x    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<   dS )ServerEventNideventdataretry)__name__
__module____qualname__r   r   str__annotations__r   r   r   int     d/var/www/html/ai-engine/env/lib/python3.11/site-packages/unstructured_client/utils/eventstreaming.pyr   r      sb         BE8C=D(3-E8C=r   r   )s   

s   

s   responsedecodersentinelreturnc                  K   t                      }d}d}|                                 2 3 d {V }|r
||z  }t          |t          |                    D ]n}|||dz            }d }	|dv rt          D ]}
t          |||
          }	|	 n|	7|||         }|t          |	          z   }t          |||          \  }}||W V  o|dk    r||d          }d}6 t          |||          \  }}||W V  d S d S 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      sw     
 [[FHG++--       e  	%xV-- 	 	A!a!e)$D#'C~%% 2  H(FH==C '{8A:&E3s88|H)%(CCNE7 a<<HII&FH7 .: "&'8<<NE7 s   Cc              #     K   t                      }d}d}|                                 D ]}|r||z  }t          |t          |                    D ]m}|||dz            }d }	|dv rt          D ]}
t          |||
          }	|	 n|	7|||         }|t          |	          z   }t          |||          \  }}||V  n|dk    r||d          }d}t          |||          \  }}||V  d S d S r   )r"   
iter_bytesr$   r%   r&   r'   r(   r)   s                r   stream_eventsr6   C   sS     
 [[FHG$$&&    	%xV-- 	 	A!a!e)$D#'C~%% 2  H(FH==C '{8A:&E3s88|H)%(CCNE7 a<<HII&FH!&'8<<NE7 r   rawc                    |                                  }t          j        d|          }d}t                      }d}|D ]}|s|                    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
k    r||dz   z  }d	}|
dk    r
||_        d	}|
dk    r,|                                rt          |          nd |_
        d	}|r|| dk    rdS |r|d d         }||_        |                                p|dk    p|dk    p|dk    }|                    d          p)|                    d          p|                    d          }|s|r+	 t          j        |          |_        n# t           $ r Y nw xY wd }|r" |t          j        |j                            }|dfS )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   sc    JJLLEH[%((EGMMED   			#A::QuW%*SYY]%:%:UQY[[!!u:: 	%(c//!""IEGEKGGf__EDL DGGd]]EHGGg(-A#e***TEKG DxOOO++z CRCy
 NNSS$'/STV^ 	 OOC  PDOOC$8$8PDOOC<P<P 	  	 	!Z--

    C 2gdj0011:s   !F; ;
GGr+   r*   sequencec                     t          |          t          |          | z
  k    rd S t          |          D ]\  }}|| |z            |k    r d S |S N)r%   	enumerate)r+   r*   rY   r.   r0   s        r   r'   r'      se    
8}}Fh.//tH%%  3(Q,3&&44 ' 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 G 				  P P P P P P P P P P P P P P P P GCLL                   #' 'n'seQh' sm' AtG	' ' ' 'Z #' 'n'seQh' sm' q$}	' ' ' 'V LP: :	:%seQh/:;CC=:
8A;: : : :zS ) u      r   