ó
    ûÞ jSŸ  ã                  ó¸  • S SK Jr  S SKrS SKJr  S SKJrJrJrJ	r	J
r
JrJrJr  S SKJrJrJrJr  SSKJrJrJrJr  SSKJr  SS	KJr  SS
KJr  SSKJrJ r   SSK!J"r"  SSK#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+  SSK,J-r-J.r.J/r/J0r0  SS jr1 " S S5      r2\	" S\2S9r3 " S S\\3   5      r4 " S S5      r5\	" S\5S9r6 " S S\\6   5      r7      SS jr8      S S jr9S!S jr:g)"é    )ÚannotationsN)ÚTracebackType)ÚTYPE_CHECKINGÚAnyÚGenericÚTypeVarÚCallableÚIterableÚIteratorÚcast)Ú	AwaitableÚAsyncIterableÚAsyncIteratorÚassert_neveré   )Úis_dictÚis_listÚconsume_sync_iteratorÚconsume_async_iterator)Ú
model_dump)Útimeout_exceptions)Úconstruct_type)ÚStreamÚAsyncStream)ÚAssistantStreamEvent)ÚRunÚTextÚMessageÚ	ImageFileÚ	TextDeltaÚMessageDeltaÚMessageContentÚMessageContentDelta)ÚRunStepÚToolCallÚRunStepDeltaÚToolCallDeltac                 ó<   • / [        5       Q[        R                  P7$ ©N)r   ÚasyncioÚTimeoutError© ó    ÚZ/var/www/html/gaurav/venv/lib/python3.13/site-packages/openai/lib/streaming/_assistants.pyÚ_timeout_exceptionsr/      s   € Ø8ÔÓ!Ð8¤7×#7Ñ#7Ñ8Ð8r-   c                  ó”  • \ rS rSr% S\S'    S'S jrS(S jrS)S jrS*S jr\	S+S j5       r
\	S,S	 j5       r\	S-S
 j5       r\	S.S j5       rS'S jrS'S jrS/S jrS0S jrS1S jrS2S jrS'S jrS3S jrS4S jrS5S jrS4S jrS6S jrS7S jrS6S jrS8S jrS'S jrS9S jrS:S jrS9S jr S;S jr!S<S  jr"S;S! jr#S=S" jr$S3S# jr%S*S$ jr&S%r'g&)>ÚAssistantEventHandleré   zIterable[str]Útext_deltasc                óò   • S U l         S U l        S U l        S U l        S U l        S U l        S U l        0 U l        0 U l        S U l	        U R                  5       U l        U R                  5       U l        S U l        g r)   )Ú_current_eventÚ_current_message_content_indexÚ_current_message_contentÚ_current_tool_call_indexÚ_current_tool_callÚ+_AssistantEventHandler__current_run_step_idÚ#_AssistantEventHandler__current_runÚ*_AssistantEventHandler__run_step_snapshotsÚ)_AssistantEventHandler__message_snapshotsÚ0_AssistantEventHandler__current_message_snapshotÚ__text_deltas__r3   Ú
__stream__Ú	_iteratorÚ_AssistantEventHandler__stream©Úselfs    r.   Ú__init__ÚAssistantEventHandler.__init__-   sx   € Ø;?ˆÔØ:>ˆÔ+Ø?CˆÔ%Ø48ˆÔ%Ø37ˆÔØ15ˆÔ"Ø)-ˆÔØ8:ˆÔ!Ø79ˆÔ Ø:>ˆÔ'à×/Ñ/Ó1ˆÔØŸ™Ó*ˆŒØ=Aˆ�r-   c                óH   • U R                   (       a  [        S5      eXl         g ©NzyA single event handler cannot be shared between multiple streams; You will need to construct a new event handler instance)rB   ÚRuntimeError©rD   Ústreams     r.   Ú_initÚAssistantEventHandler._init=   ó#   € Ø�=�=Üð Lóð ð �r-   c                ó6   • U R                   R                  5       $ r)   )rA   Ú__next__rC   s    r.   rP   ÚAssistantEventHandler.__next__E   s   € Ø�~‰~×&Ñ&Ó(Ð(r-   c              #  ó:   #   • U R                    H  nUv •  M	     g 7fr)   ©rA   ©rD   Úitems     r.   Ú__iter__ÚAssistantEventHandler.__iter__H   s   é € Ø—N”NˆDØŒJò #ùs   ‚c                ó   • U R                   $ r)   ©r5   rC   s    r.   Úcurrent_eventÚ#AssistantEventHandler.current_eventL   ó   € à×"Ñ"Ð"r-   c                ó   • U R                   $ r)   )r;   rC   s    r.   Úcurrent_runÚ!AssistantEventHandler.current_runP   ó   € à×!Ñ!Ð!r-   c                óX   • U R                   (       d  g U R                  U R                      $ r)   )r:   r<   rC   s    r.   Úcurrent_run_step_snapshotÚ/AssistantEventHandler.current_run_step_snapshotT   ó%   € à×)×)Øà×(Ñ(¨×)CÑ)CÑDÐDr-   c                ó   • U R                   $ r)   )r>   rC   s    r.   Úcurrent_message_snapshotÚ.AssistantEventHandler.current_message_snapshot[   ó   € à×.Ñ.Ð.r-   c                ó\   • U R                   (       a  U R                   R                  5         gg©zf
Close the response and release the connection.

Automatically called when the context manager exits.
N)rB   ÚcloserC   s    r.   rk   ÚAssistantEventHandler.close_   s    € ð �=�=Ø�M‰M×ÑÕ!ð r-   c                ó   • [        U 5        g©z(Waits until the stream has been consumedN)r   rC   s    r.   Ú
until_doneÚ AssistantEventHandler.until_doneh   s
   € ä˜dÕ#r-   c                ór   • U R                  5         U R                  (       d  [        S5      eU R                  $ )úBWait for the stream to finish and returns the completed Run objectúNo final run object found)ro   r;   rI   rC   s    r.   Úget_final_runÚ#AssistantEventHandler.get_final_runl   s-   € à�‰Ôà×!×!ÜÐ:Ó;Ð;à×!Ñ!Ð!r-   c                ó¶   • U R                  5         U R                  (       d  [        S5      eU R                  R                  5        Vs/ sH  oPM     sn$ s  snf )úEWait for the stream to finish and returns the steps taken in this runúNo run steps found)ro   r<   rI   Úvalues©rD   Ústeps     r.   Úget_final_run_stepsÚ)AssistantEventHandler.get_final_run_stepsu   sJ   € à�‰Ôà×(×(ÜÐ3Ó4Ð4à!%×!:Ñ!:×!AÑ!AÔ!CÓDÑ!C˜’Ñ!CÑDÐDùÒDó   Á	
Ac                ó¶   • U R                  5         U R                  (       d  [        S5      eU R                  R                  5        Vs/ sH  oPM     sn$ s  snf )úJWait for the stream to finish and returns the messages emitted in this runúNo messages found)ro   r=   rI   ry   ©rD   Úmessages     r.   Úget_final_messagesÚ(AssistantEventHandler.get_final_messages~   sJ   € à�‰Ôà×'×'ÜÐ2Ó3Ð3à'+×'?Ñ'?×'FÑ'FÔ'HÓIÑ'H˜G’Ñ'HÑIÐIùÒIr~   c              #  óV  #   • U  HŸ  nUR                   S:w  a  M  UR                  R                  R                  =(       d    /  H]  nUR                  S:X  d  M  UR
                  (       d  M(  UR
                  R                  (       d  ME  UR
                  R                  v •  M_     M¡     g 7f©Núthread.message.deltaÚtext©ÚeventÚdataÚdeltaÚcontentÚtyper‰   Úvalue©rD   r‹   Úcontent_deltas      r.   r?   Ú%AssistantEventHandler.__text_deltas__‡   s~   é € ÛˆEØ�{‰{Ð4Ó4Ùà!&§¡×!1Ñ!1×!9Ñ!9×!?¸RÒ!?�Ø ×%Ñ%¨Õ/°M×4F×4FÑ4FÈ=×K]ÑK]×Kc×KcÑKcØ'×,Ñ,×2Ñ2Ô2ó "@ò	 ùs   ‚AB)ÁB)Á+B)Â!B)c                ó   • g©z‚Fires when the stream has finished.

This happens if the stream is read to completion
or if an exception occurs during iteration.
Nr,   rC   s    r.   Úon_endÚAssistantEventHandler.on_end’   ó   � r-   c                ó   • g©z2Callback that is fired for every Server-Sent-EventNr,   ©rD   r‹   s     r.   Úon_eventÚAssistantEventHandler.on_event™   r˜   r-   c                ó   • g©z1Callback that is fired when a run step is createdNr,   ©rD   Úrun_steps     r.   Úon_run_step_createdÚ)AssistantEventHandler.on_run_step_createdœ   r˜   r-   c                ó   • g©a¨  Callback that is fired whenever a run step delta is returned from the API

The first argument is just the delta as sent by the API and the second argument
is the accumulated snapshot of the run step. For example, a tool calls event may
look like this:

# delta
tool_calls=[
    RunStepDeltaToolCallsCodeInterpreter(
        index=0,
        type='code_interpreter',
        id=None,
        code_interpreter=CodeInterpreter(input=' sympy', outputs=None)
    )
]
# snapshot
tool_calls=[
    CodeToolCall(
        id='call_wKayJlcYV12NiadiZuJXxcfx',
        code_interpreter=CodeInterpreter(input='from sympy', outputs=[]),
        type='code_interpreter',
        index=0
    )
],
Nr,   ©rD   r�   Úsnapshots      r.   Úon_run_step_deltaÚ'AssistantEventHandler.on_run_step_deltaŸ   r˜   r-   c                ó   • g©z3Callback that is fired when a run step is completedNr,   r    s     r.   Úon_run_step_doneÚ&AssistantEventHandler.on_run_step_doneº   r˜   r-   c                ó   • g©z2Callback that is fired when a tool call is createdNr,   ©rD   Ú	tool_calls     r.   Úon_tool_call_createdÚ*AssistantEventHandler.on_tool_call_created½   r˜   r-   c                ó   • g©z<Callback that is fired when a tool call delta is encounteredNr,   r¦   s      r.   Úon_tool_call_deltaÚ(AssistantEventHandler.on_tool_call_deltaÀ   r˜   r-   c                ó   • grµ   r,   r°   s     r.   Úon_tool_call_doneÚ'AssistantEventHandler.on_tool_call_doneÃ   r˜   r-   c                ó   • g©z4Fired whenever an exception happens during streamingNr,   ©rD   Ú	exceptions     r.   Úon_exceptionÚ"AssistantEventHandler.on_exceptionÆ   r˜   r-   c                ó   • g©zFires if the request times outNr,   rC   s    r.   Ú
on_timeoutÚ AssistantEventHandler.on_timeoutÉ   r˜   r-   c                ó   • g©z0Callback that is fired when a message is createdNr,   r‚   s     r.   Úon_message_createdÚ(AssistantEventHandler.on_message_createdÌ   r˜   r-   c                ó   • g©aØ  Callback that is fired whenever a message delta is returned from the API

The first argument is just the delta as sent by the API and the second argument
is the accumulated snapshot of the message. For example, a text content event may
look like this:

# delta
MessageDeltaText(
    index=0,
    type='text',
    text=Text(
        value=' Jane'
    ),
)
# snapshot
MessageContentText(
    index=0,
    type='text',
    text=Text(
        value='Certainly, Jane'
    ),
)
Nr,   r¦   s      r.   Úon_message_deltaÚ&AssistantEventHandler.on_message_deltaÏ   r˜   r-   c                ó   • g©z2Callback that is fired when a message is completedNr,   r‚   s     r.   Úon_message_doneÚ%AssistantEventHandler.on_message_doneè   r˜   r-   c                ó   • g©z;Callback that is fired when a text content block is createdNr,   ©rD   r‰   s     r.   Úon_text_createdÚ%AssistantEventHandler.on_text_createdë   r˜   r-   c                ó   • g)aB  Callback that is fired whenever a text content delta is returned
by the API.

The first argument is just the delta as sent by the API and the second argument
is the accumulated snapshot of the text. For example:

on_text_delta(TextDelta(value="The"), Text(value="The")),
on_text_delta(TextDelta(value=" solution"), Text(value="The solution")),
on_text_delta(TextDelta(value=" to"), Text(value="The solution to")),
on_text_delta(TextDelta(value=" the"), Text(value="The solution to the")),
on_text_delta(TextDelta(value=" equation"), Text(value="The solution to the equation")),
Nr,   r¦   s      r.   Úon_text_deltaÚ#AssistantEventHandler.on_text_deltaî   r˜   r-   c                ó   • g©z<Callback that is fired when a text content block is finishedNr,   rÓ   s     r.   Úon_text_doneÚ"AssistantEventHandler.on_text_doneü   r˜   r-   c                ó   • g©z;Callback that is fired when an image file block is finishedNr,   ©rD   Ú
image_files     r.   Úon_image_file_doneÚ(AssistantEventHandler.on_image_file_doneÿ   r˜   r-   c                ó„  • Xl         U R                  U5        [        UU R                  S9u  U l        nU R                  b-  U R                  U R                  U R                  R
                  '   [        UU R                  S9  U Hb  nU R                  c   eU R                  R                  UR                     nUR                  S:X  d  MG  U R                  UR                  5        Md     UR                  S:X  dP  UR                  S:X  d@  UR                  S:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S	:X  a?  UR                  U l        U R                   (       a  U R#                  U R                   5        GO±UR                  S
:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S:X  a  UR                  U l        GO^UR                  S:X  a  U R%                  UR                  5        GO1UR                  S:X  Ga×  U R                  nUc   eUR                  R&                  nUR                  Gbz  UR                   GHi  nUR                  S:X  ab  UR                  (       aQ  UR                  UR                     nUR                  S:X  d   eU R)                  UR                  UR                  5        UR                  U R*                  :w  a»  U R,                  b  U R,                  R                  S:X  a&  U R/                  U R,                  R                  5        O?U R,                  R                  S:X  a%  U R1                  U R,                  R2                  5        UR                  U l        UR                  UR                     U l        UR                  UR                     U l        GMl     U R5                  UR                  R&                  U5        GOIUR                  S:X  d  UR                  S:X  aâ  UR                  U l        UR                  U R                  UR                  R
                  '   U R*                  bz  UR                  R                  U R*                     nUR                  S:X  a  U R/                  UR                  5        O+UR                  S:X  a  U R1                  UR2                  5        U R7                  UR                  5        GOGUR                  S:X  a8  UR                  R
                  U l        U R;                  UR                  5        GOÿUR                  S:X  a  UR                  R
                  U l        GOÒUR                  S:X  Gaë  U R                  UR                  R
                     n	UR                  R&                  n
U
R<                  (       Gay  U
R<                  R                  S:X  Ga^  U
R<                  R>                  GbF  U	R<                  R                  S:X  d   eU
R<                  R>                   GH  nUR                  U R@                  :X  a3  U RC                  UU	R<                  R>                  UR                     5        UR                  U R@                  :w  a|  U R                   b  U R#                  U R                   5        UR                  U l         U	R<                  R>                  UR                     U l        U RE                  U R                   5        U	R<                  R>                  UR                     U l        GM     U RG                  UR                  R&                  U	5        OÖUR                  S:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S:X  aO  U R                   (       a  U R#                  U R                   5        U RI                  UR                  5        S U l        OGUR                  S:X  d   UR                  S:X  d  UR                  S:X  a  O[J        (       a  [M        U5        S U l         g ©N)r‹   rf   )r‹   Úrun_step_snapshotsr‰   zthread.run.completedzthread.run.cancelledzthread.run.expiredzthread.run.failedzthread.run.requires_actionzthread.run.incompletezthread.run.createdzthread.run.in_progresszthread.run.cancellingzthread.run.queuedúthread.message.createdrˆ   rà   zthread.message.completedzthread.message.incompleteúthread.run.step.createdzthread.run.step.in_progressúthread.run.step.deltaÚ
tool_callszthread.run.step.completedzthread.run.step.cancelledzthread.run.step.expiredzthread.run.step.failedzthread.createdzthread.message.in_progressÚerror)'r5   rœ   Úaccumulate_eventr>   r=   ÚidÚaccumulate_run_stepr<   rŽ   Úindexr�   rÔ   r‰   r‹   rŒ   r;   r9   r¹   rÇ   r�   r×   r6   r7   rÛ   rá   rà   rË   rÏ   r:   r¢   Ústep_detailsré   r8   r¶   r²   r¨   r¬   r   r   ©rD   r‹   Únew_contentr’   Úblockr§   Úmessage_deltaÚsnapshot_contentrŽ   Ústep_snapshotÚrun_step_deltaÚtool_call_deltas               r.   Ú_emit_sse_eventÚ%AssistantEventHandler._emit_sse_event  sr  € Ø#ÔØ�‰�eÔä7GØØ%)×%DÑ%Dñ8
Ñ4ˆÔ'¨ð ×*Ñ*Ñ6ØKO×KjÑKjˆD×$Ñ$ T×%DÑ%D×%GÑ%GÑHäØØ#×8Ñ8ò	
ó
 )ˆMØ×2Ñ2Ñ>Ð>Ð>à×3Ñ3×;Ñ;¸M×<OÑ<OÑPˆEØ�z‰z˜VÕ#Ø×$Ñ$ U§Z¡ZÖ0ñ )ð �K‰KÐ1Ó1Ø�{‰{Ð4Ó4Ø�{‰{Ð2Ó2Ø�{‰{Ð1Ó1Ø�{‰{Ð:Ó:Ø�{‰{Ð5Ó5à!&§¡ˆDÔØ×&×&Ø×&Ñ& t×'>Ñ'>Ô?ùà�K‰KÐ/Ó/Ø�{‰{Ð6Ó6Ø�{‰{Ð5Ó5Ø�{‰{Ð1Ó1à!&§¡ˆDÖØ�[‰[Ð4Ó4Ø×#Ñ# E§J¡JÖ/Ø�[‰[Ð2Ô2Ø×6Ñ6ˆHØÑ'Ð'Ð'à!ŸJ™J×,Ñ,ˆMØ×$Ñ$Ò0Ø%2×%:Õ%:�MØ$×)Ñ)¨VÓ3¸×8J×8JØ+3×+;Ñ+;¸M×<OÑ<OÑ+PÐ(Ø/×4Ñ4¸Ó>Ð>Ð>Ø×*Ñ*¨=×+=Ñ+=Ð?O×?TÑ?TÔUð
 %×*Ñ*¨d×.QÑ.QÓQØ×8Ñ8ÑDØ#×<Ñ<×AÑAÀVÓKØ $× 1Ñ 1°$×2OÑ2O×2TÑ2TÕ UØ!%×!>Ñ!>×!CÑ!CÀ|Ó!SØ $× 7Ñ 7¸×8UÑ8U×8`Ñ8`Ô aà>K×>QÑ>Q˜Ô;Ø8@×8HÑ8HÈ×I\ÑI\Ñ8]˜Ô5ð 5=×4DÑ4DÀ]×EXÑEXÑ4Y�D×1ñ) &;ð, ×!Ñ! %§*¡*×"2Ñ"2°HÖ=Ø�[‰[Ð6Ó6¸%¿+¹+ÐIdÓ:dØ.3¯j©jˆDÔ+Ø6;·j±jˆD×$Ñ$ U§Z¡Z§]¡]Ñ3à×2Ñ2Ñ>ØŸ*™*×,Ñ,¨T×-PÑ-PÑQ�Ø—<‘< 6Ó)Ø×%Ñ% g§l¡lÕ3Ø—\‘\ \Ó1Ø×+Ñ+¨G×,>Ñ,>Ô?à× Ñ  §¡Ö,Ø�[‰[Ð5Ó5Ø).¯©¯©ˆDÔ&Ø×$Ñ$ U§Z¡ZÖ0Ø�[‰[Ð9Ó9Ø).¯©¯©ˆDÖ&Ø�[‰[Ð3Ô3Ø ×5Ñ5°e·j±j·m±mÑDˆMà"ŸZ™Z×-Ñ-ˆNà×+×+Ð+Ø"×/Ñ/×4Ñ4¸ÔDØ"×/Ñ/×:Ñ:ÒFà$×1Ñ1×6Ñ6¸,ÓFÐFÐFØ'5×'BÑ'B×'MÕ'M�OØ&×,Ñ,°×0MÑ0MÓMØ×/Ñ/Ø+Ø)×6Ñ6×AÑAÀ/×BWÑBWÑXôð '×,Ñ,°×0MÑ0MÓMØ×2Ñ2Ñ>Ø ×2Ñ2°4×3JÑ3JÔKà8G×8MÑ8M˜Ô5Ø2?×2LÑ2L×2WÑ2WÐXg×XmÑXmÑ2n˜Ô/Ø×1Ñ1°$×2IÑ2IÔJð /<×.HÑ.H×.SÑ.SÐTc×TiÑTiÑ.j�D×+ñ' (Nð* ×"Ñ"Ø—
‘
× Ñ Øõð
 �K‰KÐ6Ó6Ø�{‰{Ð9Ó9Ø�{‰{Ð7Ó7Ø�{‰{Ð6Ó6à×&×&Ø×&Ñ& t×'>Ñ'>Ô?à×!Ñ! %§*¡*Ô-Ø)-ˆDÕ&Ø�[‰[Ð,Ó,°·±Ð?[Ó0[Ð_d×_jÑ_jÐnuÓ_uà÷ Š}Ü˜UÔ#à"ˆÕr-   c              #  ó€  #   • U R                   nU(       d  [        S5      e U H  nU R                  U5        Uv •  M      U R                  5         g ! [        5        a'  nU R	                  5         U R                  U5        e S nAf[         a  nU R                  U5        e S nAff = f! U R                  5         f = f7f©NzStream has not been started yet)rB   rI   rø   r/   rÃ   r¿   Ú	Exceptionr–   ©rD   rK   r‹   Úexcs       r.   r@   Ú AssistantEventHandler.__stream__“  sŸ   é € Ø—‘ˆÞÜÐ@ÓAÐAð	Û�Ø×$Ñ$ UÔ+à”ò  ð �K‰K�Møô #Ó$ó 	Ø�O‰OÔØ×Ñ˜cÔ"ØûÜó 	Ø×Ñ˜cÔ"Øûð	ûð �K‰K�Müs@   ‚B>¢A ÁB>ÁB&Á "BÂB&ÂB!Â!B&Â&B) Â)B;Â;B>©Ú__current_message_snapshotÚ__current_runÚ__current_run_step_idÚ__message_snapshotsÚ__run_step_snapshotsÚ__streamr5   r7   r6   r9   r8   rA   r3   N©ÚreturnÚNone)rK   zStream[AssistantStreamEvent]r  r	  ©r  r   )r  zIterator[AssistantStreamEvent]©r  zAssistantStreamEvent | None©r  z
Run | None©r  zRunStep | None©r  úMessage | None©r  r   ©r  zlist[RunStep]©r  zlist[Message])r  zIterator[str]©r‹   r   r  r	  ©r¡   r$   r  r	  ©r�   r&   r§   r$   r  r	  ©r±   r%   r  r	  ©r�   r'   r§   r%   r  r	  ©r¾   rü   r  r	  ©rƒ   r   r  r	  ©r�   r!   r§   r   r  r	  ©r‰   r   r  r	  ©r�   r    r§   r   r  r	  ©rà   r   r  r	  )(Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__annotations__rE   rL   rP   rV   ÚpropertyrZ   r^   rb   rf   rk   ro   rt   r|   r„   r?   r–   rœ   r¢   r¨   r¬   r²   r¶   r¹   r¿   rÃ   rÇ   rË   rÏ   rÔ   r×   rÛ   rá   rø   r@   Ú__static_attributes__r,   r-   r.   r1   r1      s   ‡ ØÓð
ôBô ô)ôð ó#ó ð#ð ó"ó ð"ð óEó ðEð ó/ó ð/ô"ô$ô"ôEôJô3ôôAô@ôô6BôAôKôKôCô-ô?ôô2AôJôôKôJôO#÷br-   r1   ÚAssistantEventHandlerT)Úboundc                  óR   • \ rS rSrSr      SS jrS	S jr        S
S jrSrg)ÚAssistantStreamManageri«  zÚWrapper over AssistantStreamEventHandler that is returned by `.stream()`
so that a context manager can be used.

```py
with client.threads.create_and_run_stream(...) as stream:
    for event in stream:
        ...
```
c               ó*   • S U l         X l        Xl        g r)   )Ú_AssistantStreamManager__streamÚ&_AssistantStreamManager__event_handlerÚ$_AssistantStreamManager__api_request©rD   Úapi_requestÚevent_handlers      r.   rE   ÚAssistantStreamManager.__init__¶  s   € ð >BˆŒØ,ÔØ(Õr-   c                óŽ   • U R                  5       U l        U R                  R                  U R                  5        U R                  $ r)   )r,  r*  r+  rL   rC   s    r.   Ú	__enter__Ú AssistantStreamManager.__enter__À  s6   € Ø×*Ñ*Ó,ˆŒØ×Ñ×"Ñ" 4§=¡=Ô1Ø×#Ñ#Ð#r-   c                óT   • U R                   b  U R                   R                  5         g g r)   )r*  rk   ©rD   Úexc_typerþ   Úexc_tbs       r.   Ú__exit__ÚAssistantStreamManager.__exit__Å  s#   € ð �=‰=Ñ$Ø�M‰M×ÑÕ!ð %r-   ©Ú__api_requestÚ__event_handlerr  N)r.  z*Callable[[], Stream[AssistantStreamEvent]]r/  r%  r  r	  )r  r%  ©r6  ztype[BaseException] | Nonerþ   zBaseException | Noner7  zTracebackType | Noner  r	  )	r  r  r   r!  Ú__doc__rE   r2  r8  r$  r,   r-   r.   r(  r(  «  sX   † ñð)à?ð)ð .ð	)ð
 
ô)ô$ð
"à,ð"ð "ð"ð %ð	"ð
 
÷"r-   r(  c                  ó”  • \ rS rSr% S\S'    S'S jrS(S jrS)S jrS*S jrS'S jr	\
S+S	 j5       r\
S,S
 j5       r\
S-S j5       r\
S.S j5       rS'S jrS/S jrS0S jrS1S jrS2S jrS'S jrS3S jrS4S jrS5S jrS4S jrS6S jrS7S jrS6S jrS8S jrS'S jrS9S jrS:S jrS9S jr S;S jr!S<S  jr"S;S! jr#S=S" jr$S3S# jr%S*S$ jr&S%r'g&)>ÚAsyncAssistantEventHandleriÏ  zAsyncIterable[str]r3   c                óò   • S U l         S U l        S U l        S U l        S U l        S U l        S U l        0 U l        0 U l        S U l	        U R                  5       U l        U R                  5       U l        S U l        g r)   )r5   r6   r7   r8   r9   Ú0_AsyncAssistantEventHandler__current_run_step_idÚ(_AsyncAssistantEventHandler__current_runÚ/_AsyncAssistantEventHandler__run_step_snapshotsÚ._AsyncAssistantEventHandler__message_snapshotsÚ5_AsyncAssistantEventHandler__current_message_snapshotr?   r3   r@   rA   Ú#_AsyncAssistantEventHandler__streamrC   s    r.   rE   Ú#AsyncAssistantEventHandler.__init__Ý  sx   € Ø;?ˆÔØ:>ˆÔ+Ø?CˆÔ%Ø48ˆÔ%Ø37ˆÔØ15ˆÔ"Ø)-ˆÔØ8:ˆÔ!Ø79ˆÔ Ø:>ˆÔ'à×/Ñ/Ó1ˆÔØŸ™Ó*ˆŒØBFˆ�r-   c                óH   • U R                   (       a  [        S5      eXl         g rH   )rG  rI   rJ   s     r.   rL   Ú AsyncAssistantEventHandler._inití  rN   r-   c              ƒ  óR   #   • U R                   R                  5       I S h  v•N $  N7fr)   )rA   Ú	__anext__rC   s    r.   rL  Ú$AsyncAssistantEventHandler.__anext__õ  s   é € Ø—^‘^×-Ñ-Ó/×/Ð/Ñ/ùs   ‚' %¡'c               óJ   #   • U R                     S h  v•N nU7v •  M   N
 g 7fr)   rS   rT   s     r.   Ú	__aiter__Ú$AsyncAssistantEventHandler.__aiter__ø  s   é € ØŸ.š.÷ 	�$Ø�Jñ	™.ùs   ‚#�!“”!—#Ÿ!¡#c              ƒ  óx   #   • U R                   (       a#  U R                   R                  5       I Sh  v•N   gg N7frj   )rG  rk   rC   s    r.   rk   Ú AsyncAssistantEventHandler.closeü  s,   é € ð �=�=Ø—-‘-×%Ñ%Ó'×'Ñ'ð Ù'ùs   ‚/:±8²:c                ó   • U R                   $ r)   rY   rC   s    r.   rZ   Ú(AsyncAssistantEventHandler.current_event  r\   r-   c                ó   • U R                   $ r)   )rC  rC   s    r.   r^   Ú&AsyncAssistantEventHandler.current_run	  r`   r-   c                óX   • U R                   (       d  g U R                  U R                      $ r)   )rB  rD  rC   s    r.   rb   Ú4AsyncAssistantEventHandler.current_run_step_snapshot  rd   r-   c                ó   • U R                   $ r)   )rF  rC   s    r.   rf   Ú3AsyncAssistantEventHandler.current_message_snapshot  rh   r-   c              ƒ  ó6   #   • [        U 5      I Sh  v•N   g N7frn   )r   rC   s    r.   ro   Ú%AsyncAssistantEventHandler.until_done  s   é € ä$ TÓ*×*Ó*ùs   ‚‘’c              ƒ  óŽ   #   • U R                  5       I Sh  v•N   U R                  (       d  [        S5      eU R                  $  N,7f)rr   Nrs   )ro   rC  rI   rC   s    r.   rt   Ú(AsyncAssistantEventHandler.get_final_run  s;   é € à�o‰oÓ×Ðà×!×!ÜÐ:Ó;Ð;à×!Ñ!Ð!ñ 	 ùs   ‚A–A—-Ac              ƒ  óÒ   #   • U R                  5       I Sh  v•N   U R                  (       d  [        S5      eU R                  R                  5        Vs/ sH  oPM     sn$  NIs  snf 7f)rw   Nrx   )ro   rD  rI   ry   rz   s     r.   r|   Ú.AsyncAssistantEventHandler.get_final_run_steps%  s[   é € à�o‰oÓ×Ðà×(×(ÜÐ3Ó4Ð4à!%×!:Ñ!:×!AÑ!AÔ!CÓDÑ!C˜’Ñ!CÑDÐDñ 	 ùò
 Eùó!   ‚A'–A —<A'Á
A"ÁA'Á"A'c              ƒ  óÒ   #   • U R                  5       I Sh  v•N   U R                  (       d  [        S5      eU R                  R                  5        Vs/ sH  oPM     sn$  NIs  snf 7f)r€   Nr�   )ro   rE  rI   ry   r‚   s     r.   r„   Ú-AsyncAssistantEventHandler.get_final_messages.  s[   é € à�o‰oÓ×Ðà×'×'ÜÐ2Ó3Ð3à'+×'?Ñ'?×'FÑ'FÔ'HÓIÑ'H˜G’Ñ'HÑIÐIñ 	 ùò
 Jùra  c               óf  #   • U   S h  v•N nUR                   S:w  a  M  UR                  R                  R                  =(       d    /  H^  nUR                  S:X  d  M  UR
                  (       d  M(  UR
                  R                  (       d  ME  UR
                  R                  7v •  M`     M¨   N£
 g 7fr‡   rŠ   r‘   s      r.   r?   Ú*AsyncAssistantEventHandler.__text_deltas__7  s…   é € Ù÷ 	3�%Ø�{‰{Ð4Ó4Ùà!&§¡×!1Ñ!1×!9Ñ!9×!?¸RÒ!?�Ø ×%Ñ%¨Õ/°M×4F×4FÑ4FÈ=×K]ÑK]×Kc×KcÑKcØ'×,Ñ,×2Ñ2Õ2ó "@ñ		3™4ùs8   ‚B1…B/‰B-ŠB/�AB1ÁB1Á1B1ÂB1Â-B/Â/B1c              ƒ  ó   #   • g7fr•   r,   rC   s    r.   r–   Ú!AsyncAssistantEventHandler.on_endB  ó   é � ùó   ‚c              ƒ  ó   #   • g7frš   r,   r›   s     r.   rœ   Ú#AsyncAssistantEventHandler.on_eventI  rh  ri  c              ƒ  ó   #   • g7frŸ   r,   r    s     r.   r¢   Ú.AsyncAssistantEventHandler.on_run_step_createdL  rh  ri  c              ƒ  ó   #   • g7fr¥   r,   r¦   s      r.   r¨   Ú,AsyncAssistantEventHandler.on_run_step_deltaO  rh  ri  c              ƒ  ó   #   • g7fr«   r,   r    s     r.   r¬   Ú+AsyncAssistantEventHandler.on_run_step_donej  rh  ri  c              ƒ  ó   #   • g7fr¯   r,   r°   s     r.   r²   Ú/AsyncAssistantEventHandler.on_tool_call_createdm  rh  ri  c              ƒ  ó   #   • g7frµ   r,   r¦   s      r.   r¶   Ú-AsyncAssistantEventHandler.on_tool_call_deltap  rh  ri  c              ƒ  ó   #   • g7frµ   r,   r°   s     r.   r¹   Ú,AsyncAssistantEventHandler.on_tool_call_dones  rh  ri  c              ƒ  ó   #   • g7fr¼   r,   r½   s     r.   r¿   Ú'AsyncAssistantEventHandler.on_exceptionv  rh  ri  c              ƒ  ó   #   • g7frÂ   r,   rC   s    r.   rÃ   Ú%AsyncAssistantEventHandler.on_timeouty  rh  ri  c              ƒ  ó   #   • g7frÆ   r,   r‚   s     r.   rÇ   Ú-AsyncAssistantEventHandler.on_message_created|  rh  ri  c              ƒ  ó   #   • g7frÊ   r,   r¦   s      r.   rË   Ú+AsyncAssistantEventHandler.on_message_delta  rh  ri  c              ƒ  ó   #   • g7frÎ   r,   r‚   s     r.   rÏ   Ú*AsyncAssistantEventHandler.on_message_done˜  rh  ri  c              ƒ  ó   #   • g7frÒ   r,   rÓ   s     r.   rÔ   Ú*AsyncAssistantEventHandler.on_text_created›  rh  ri  c              ƒ  ó   #   • g7f)aD  Callback that is fired whenever a text content delta is returned
by the API.

The first argument is just the delta as sent by the API and the second argument
is the accumulated snapshot of the text. For example:

on_text_delta(TextDelta(value="The"), Text(value="The")),
on_text_delta(TextDelta(value=" solution"), Text(value="The solution")),
on_text_delta(TextDelta(value=" to"), Text(value="The solution to")),
on_text_delta(TextDelta(value=" the"), Text(value="The solution to the")),
on_text_delta(TextDelta(value=" equation"), Text(value="The solution to the equivalent")),
Nr,   r¦   s      r.   r×   Ú(AsyncAssistantEventHandler.on_text_deltaž  rh  ri  c              ƒ  ó   #   • g7frÚ   r,   rÓ   s     r.   rÛ   Ú'AsyncAssistantEventHandler.on_text_done¬  rh  ri  c              ƒ  ó   #   • g7frÞ   r,   rß   s     r.   rá   Ú-AsyncAssistantEventHandler.on_image_file_done¯  rh  ri  c              ƒ  ó  #   • Xl         U R                  U5      I S h  v•N   [        UU R                  S9u  U l        nU R                  b-  U R                  U R                  U R                  R
                  '   [        UU R                  S9  U Hj  nU R                  c   eU R                  R                  UR                     nUR                  S:X  d  MG  U R                  UR                  5      I S h  v•N   Ml     UR                  S:X  dP  UR                  S:X  d@  UR                  S:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S	:X  aG  UR                  U l        U R                   (       a#  U R#                  U R                   5      I S h  v•N   GO)UR                  S
:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S:X  a  UR                  U l        GOÖUR                  S:X  a%  U R%                  UR                  5      I S h  v•N   GO¡UR                  S:X  Ga÷  U R                  nUc   eUR                  R&                  nUR                  Gb’  UR                   GH�  nUR                  S:X  aj  UR                  (       aY  UR                  UR                     nUR                  S:X  d   eU R)                  UR                  UR                  5      I S h  v•N   UR                  U R*                  :w  aË  U R,                  b�  U R,                  R                  S:X  a.  U R/                  U R,                  R                  5      I S h  v•N   OGU R,                  R                  S:X  a-  U R1                  U R,                  R2                  5      I S h  v•N   UR                  U l        UR                  UR                     U l        UR                  UR                     U l        GM„     U R5                  UR                  R&                  U5      I S h  v•N   GO™UR                  S:X  d  UR                  S:X  aú  UR                  U l        UR                  U R                  UR                  R
                  '   U R*                  bŠ  UR                  R                  U R*                     nUR                  S:X  a$  U R/                  UR                  5      I S h  v•N   O3UR                  S:X  a#  U R1                  UR2                  5      I S h  v•N   U R7                  UR                  5      I S h  v•N   GOUR                  S:X  a@  UR                  R
                  U l        U R;                  UR                  5      I S h  v•N   GO/UR                  S:X  a  UR                  R
                  U l        GOUR                  S:X  Ga  U R                  UR                  R
                     n	UR                  R&                  n
U
R<                  (       Ga‘  U
R<                  R                  S:X  Gav  U
R<                  R>                  Gb^  U	R<                  R                  S:X  d   eU
R<                  R>                   GH'  nUR                  U R@                  :X  a;  U RC                  UU	R<                  R>                  UR                     5      I S h  v•N   UR                  U R@                  :w  aŒ  U R                   b#  U R#                  U R                   5      I S h  v•N   UR                  U l         U	R<                  R>                  UR                     U l        U RE                  U R                   5      I S h  v•N   U	R<                  R>                  UR                     U l        GM*     U RG                  UR                  R&                  U	5      I S h  v•N   OæUR                  S:X  d0  UR                  S:X  d   UR                  S:X  d  UR                  S:X  a_  U R                   (       a#  U R#                  U R                   5      I S h  v•N   U RI                  UR                  5      I S h  v•N   S U l        OGUR                  S:X  d   UR                  S:X  d  UR                  S:X  a  O[J        (       a  [M        U5        S U l         g  GN· GNä GN> GN¹ GNê GN GN: GN½ GNý GNÌ GN¬ GN_ GN GNÒ GNy GN! N® N�7frä   )'r5   rœ   rë   rF  rE  rì   rí   rD  rŽ   rî   r�   rÔ   r‰   r‹   rŒ   rC  r9   r¹   rÇ   r�   r×   r6   r7   rÛ   rá   rà   rË   rÏ   rB  r¢   rï   ré   r8   r¶   r²   r¨   r¬   r   r   rð   s               r.   rø   Ú*AsyncAssistantEventHandler._emit_sse_event²  sC  é € Ø#ÔØ�m‰m˜EÓ"×"Ð"ä7GØØ%)×%DÑ%Dñ8
Ñ4ˆÔ'¨ð ×*Ñ*Ñ6ØKO×KjÑKjˆD×$Ñ$ T×%DÑ%D×%GÑ%GÑHäØØ#×8Ñ8ò	
ó
 )ˆMØ×2Ñ2Ñ>Ð>Ð>à×3Ñ3×;Ñ;¸M×<OÑ<OÑPˆEØ�z‰z˜VÕ#Ø×*Ñ*¨5¯:©:Ó6×6Ò6ñ )ð �K‰KÐ1Ó1Ø�{‰{Ð4Ó4Ø�{‰{Ð2Ó2Ø�{‰{Ð1Ó1Ø�{‰{Ð:Ó:Ø�{‰{Ð5Ó5à!&§¡ˆDÔØ×&×&Ø×,Ñ,¨T×-DÑ-DÓE×EÐEùà�K‰KÐ/Ó/Ø�{‰{Ð6Ó6Ø�{‰{Ð5Ó5Ø�{‰{Ð1Ó1à!&§¡ˆDÖØ�[‰[Ð4Ó4Ø×)Ñ)¨%¯*©*Ó5×5Ò5Ø�[‰[Ð2Ô2Ø×6Ñ6ˆHØÑ'Ð'Ð'à!ŸJ™J×,Ñ,ˆMØ×$Ñ$Ò0Ø%2×%:Õ%:�MØ$×)Ñ)¨VÓ3¸×8J×8JØ+3×+;Ñ+;¸M×<OÑ<OÑ+PÐ(Ø/×4Ñ4¸Ó>Ð>Ð>Ø"×0Ñ0°×1CÑ1CÐEU×EZÑEZÓ[×[Ð[ð
 %×*Ñ*¨d×.QÑ.QÓQØ×8Ñ8ÑDØ#×<Ñ<×AÑAÀVÓKØ&*×&7Ñ&7¸×8UÑ8U×8ZÑ8ZÓ&[× [Ñ [Ø!%×!>Ñ!>×!CÑ!CÀ|Ó!SØ&*×&=Ñ&=¸d×>[Ñ>[×>fÑ>fÓ&g× gÐ gà>K×>QÑ>Q˜Ô;Ø8@×8HÑ8HÈ×I\ÑI\Ñ8]˜Ô5ð 5=×4DÑ4DÀ]×EXÑEXÑ4Y�D×1ñ) &;ð, ×'Ñ'¨¯
©
×(8Ñ(8¸(ÓC×CÒCØ�[‰[Ð6Ó6¸%¿+¹+ÐIdÓ:dØ.3¯j©jˆDÔ+Ø6;·j±jˆD×$Ñ$ U§Z¡Z§]¡]Ñ3à×2Ñ2Ñ>ØŸ*™*×,Ñ,¨T×-PÑ-PÑQ�Ø—<‘< 6Ó)Ø×+Ñ+¨G¯L©LÓ9×9Ñ9Ø—\‘\ \Ó1Ø×1Ñ1°'×2DÑ2DÓE×EÐEà×&Ñ& u§z¡zÓ2×2Ò2Ø�[‰[Ð5Ó5Ø).¯©¯©ˆDÔ&Ø×*Ñ*¨5¯:©:Ó6×6Ò6Ø�[‰[Ð9Ó9Ø).¯©¯©ˆDÖ&Ø�[‰[Ð3Ô3Ø ×5Ñ5°e·j±j·m±mÑDˆMà"ŸZ™Z×-Ñ-ˆNà×+×+Ð+Ø"×/Ñ/×4Ñ4¸ÔDØ"×/Ñ/×:Ñ:ÒFà$×1Ñ1×6Ñ6¸,ÓFÐFÐFØ'5×'BÑ'B×'MÕ'M�OØ&×,Ñ,°×0MÑ0MÓMØ"×5Ñ5Ø+Ø)×6Ñ6×AÑAÀ/×BWÑBWÑXó÷ ð ð '×,Ñ,°×0MÑ0MÓMØ×2Ñ2Ñ>Ø"&×"8Ñ"8¸×9PÑ9PÓ"Q×QÐQà8G×8MÑ8M˜Ô5Ø2?×2LÑ2L×2WÑ2WÐXg×XmÑXmÑ2n˜Ô/Ø"×7Ñ7¸×8OÑ8OÓP×PÐPð /<×.HÑ.H×.SÑ.SÐTc×TiÑTiÑ.j�D×+ñ' (Nð* ×(Ñ(Ø—
‘
× Ñ Øó÷ ñ ð
 �K‰KÐ6Ó6Ø�{‰{Ð9Ó9Ø�{‰{Ð7Ó7Ø�{‰{Ð6Ó6à×&×&Ø×,Ñ,¨T×-DÑ-DÓE×EÐEà×'Ñ'¨¯
©
Ó3×3Ð3Ø)-ˆDÕ&Ø�[‰[Ð,Ó,°·±Ð?[Ó0[Ð_d×_jÑ_jÐnuÓ_uà÷ Š}Ü˜UÔ#à"ˆÕò[ 	#ò& 7ò Fò 6ò \ò !\â gò Dò :âEâ2ò 7òò Rò Qò
ñ Fá3ùsV  ‚d�cžB3dÃdÃ3cÃ4B(dÆcÆBdÈ$cÈ%CdË6c Ë7A-dÍ$c#Í%AdÎ,c&Î-A?dÐ,c)Ð-CdÓ/c,Ó03dÔ#c/Ô$"dÕc2ÕAdÖc5ÖEdÛc8Û A	dÜ)c;Ü*AdÞc>ÞAdß dß!A4dádá"dá8dá9Adãdãdãdã dã#dã&dã)dã,dã/dã2dã5dã8dã;dã>dädädädc               ó   #   • U R                   nU(       d  [        S5      e U  S h  v•N nU R                  U5      I S h  v•N   U7v •  M)   N$ N
 Or! [        5        a9  nU R	                  5       I S h  v•N    U R                  U5      I S h  v•N    e S nAf[         a   nU R                  U5      I S h  v•N    e S nAff = f U R                  5       I S h  v•N    g ! U R                  5       I S h  v•N    f = f7frû   )rG  rI   rø   r/   rÃ   r¿   rü   r–   rý   s       r.   r@   Ú%AsyncAssistantEventHandler.__stream__C  sÓ   é € Ø—‘ˆÞÜÐ@ÓAÐAð	 Ù%÷ �eØ×*Ñ*¨5Ó1×1Ð1à•ñÙ1ñ  &øô #Ó$ó 	Ø—/‘/Ó#×#Ñ#Ø×#Ñ# CÓ(×(Ñ(ØûÜó 	Ø×#Ñ# CÓ(×(Ñ(Øûð	úð  &ð —+‘+“-×Òø�$—+‘+“-×Òüs´   ‚C>¢A ¤A¨A©A¬A ÁAÁA ÁAÁA ÁA ÁC  ÁCÁ!BÁ4A7Á5BÂBÂBÂCÂ"B=Â6B9Â7B=Â=CÃC  ÃC>ÃCÃC>Ã C;Ã4C7Ã5C;Ã;C>r   Nr  )rK   z!AsyncStream[AssistantStreamEvent]r  r	  r
  )r  z#AsyncIterator[AssistantStreamEvent]r  r  r  r  r  r  r  )r  zAsyncIterator[str]r  r  r  r  r  r  r  r  r  r  r  )(r  r  r   r!  r"  rE   rL   rL  rO  rk   r#  rZ   r^   rb   rf   ro   rt   r|   r„   r?   r–   rœ   r¢   r¨   r¬   r²   r¶   r¹   r¿   rÃ   rÇ   rË   rÏ   rÔ   r×   rÛ   rá   rø   r@   r$  r,   r-   r.   r@  r@  Ï  s   ‡ Ø#Ó#ð
ôGô ô0ôô(ð ó#ó ð#ð ó"ó ð"ð óEó ðEð ó/ó ð/ô+ô"ôEôJô3ôôAô@ôô6BôAôKôKôCô-ô?ôô2AôJôôKôJôO#÷b r-   r@  ÚAsyncAssistantEventHandlerTc                  óR   • \ rS rSrSr      SS jrS	S jr        S
S jrSrg)ÚAsyncAssistantStreamManageri[  a  Wrapper over AsyncAssistantStreamEventHandler that is returned by `.stream()`
so that an async context manager can be used without `await`ing the
original client call.

```py
async with client.threads.create_and_run_stream(...) as stream:
    async for event in stream:
        ...
```
c               ó*   • S U l         X l        Xl        g r)   )Ú$_AsyncAssistantStreamManager__streamÚ+_AsyncAssistantStreamManager__event_handlerÚ)_AsyncAssistantStreamManager__api_requestr-  s      r.   rE   Ú$AsyncAssistantStreamManager.__init__g  s   € ð CGˆŒØ,ÔØ(Õr-   c              ƒ  ó¢   #   • U R                   I S h  v•N U l        U R                  R                  U R                  5        U R                  $  N:7fr)   )r”  r’  r“  rL   rC   s    r.   Ú
__aenter__Ú&AsyncAssistantStreamManager.__aenter__q  s>   é € Ø"×0Ñ0×0ˆŒØ×Ñ×"Ñ" 4§=¡=Ô1Ø×#Ñ#Ð#ñ 1ùs   ‚A’A“;Ac              ƒ  óp   #   • U R                   b#  U R                   R                  5       I S h  v•N   g g  N7fr)   )r’  rk   r5  s       r.   Ú	__aexit__Ú%AsyncAssistantStreamManager.__aexit__v  s/   é € ð �=‰=Ñ$Ø—-‘-×%Ñ%Ó'×'Ñ'ð %Ù'ùs   ‚+6­4®6r:  N)r.  z,Awaitable[AsyncStream[AssistantStreamEvent]]r/  rŽ  r  r	  )r  rŽ  r=  )	r  r  r   r!  r>  rE   r—  rš  r$  r,   r-   r.   r�  r�  [  sX   † ñ	ð)àAð)ð 3ð	)ð
 
ô)ô$ð
(à,ð(ð "ð(ð %ð	(ð
 
÷(r-   r�  c                ó¨  • U R                   S:X  a#  U R                  XR                  R                  '   g U R                   S:X  a�  U R                  nXR                     nUR                  (       ad  [	        [        S[        USSS95      [        S[        UR                  SSS95      5      n[        [        [        [        US95      XR                  '   g )Nrç   rè   údict[object, object]TF©Úexclude_unsetÚwarnings©Útype_r�   )	r‹   rŒ   rì   r�   Úaccumulate_deltar   r   r$   r   )r‹   rå   rŒ   r§   Úmergeds        r.   rí   rí   €  s²   € ð
 ‡{�{Ð/Ó/Ø,1¯J©JÐŸ:™:Ÿ=™=Ñ)Øà‡{�{Ð-Ó-Ø�z‰zˆØ%§g¡gÑ.ˆà�:�:Ü%ÜØ*Ü˜x°tÀeÑLóô Ø*Ü˜tŸz™z¸ÈÑNóó	ˆFô /3´7¼NÔQXÐ`fÑ<gÓ.hÐŸ{™{Ñ+àr-   c                ó*  • U R                   S:X  a  U R                  / 4$ / nU R                   S:w  a  U/ 4$ U(       d  [        S5      eU R                  nUR                  R                  (       aª  UR                  R                   H�  n UR                  UR
                     n[        [        S[        USSS95      [        S[        USSS95      5      n[        [        [        [        [        [        5      US95      UR                  UR
                  '   M’     X4$ ! [         am    UR                  R                  UR
                  [        [        [        [        [        [        5      [        USSS9S95      5        UR                  U5         GM  f = f)	zIReturns a tuple of message snapshot and newly created text message deltasræ   rˆ   z5Encountered a message delta with no previous snapshotr�  TFrž  r¡  )r‹   rŒ   rI   r�   rŽ   rî   r£  r   r   r"   r   r   Ú
IndexErrorÚinsertÚappend)r‹   rf   rñ   rŒ   r’   rò   r¤  s          r.   rë   rë   �  s}  € ð ‡{�{Ð.Ó.Ø�z‰z˜2ˆ~Ðà-/€Kà‡{�{Ð,Ó,Ø'¨Ð+Ð+æ#ÜÐRÓSÐSà�:‰:€DØ‡z�z××Ø!ŸZ™Z×/Ô/ˆMð!Ø0×8Ñ8¸×9LÑ9LÑM�ô *ÜØ.Ü" 5¸ÀuÑMóô Ø.Ü" =ÀÈuÑUóó	�ô IMÜ"Ü"ä"¤3¬Ó7Ø$ñóIÐ(×0Ñ0°×1DÑ1DÓEñ7 0ðH $Ð0Ð0øôC ó 2Ø(×0Ñ0×7Ñ7Ø!×'Ñ'ÜÜ&Ü&ä"&¤s¬NÓ";Ü",¨]È$ÐY^Ñ"_ñóô
ð ×"Ñ" =×1Ð1ð2ús   ÂDÄA2FÆFc                óÜ  • UR                  5        GH“  u  p#X ;  a  X0U'   M  X   nUc  X0U'   M  US:X  d  US:X  a  X0U'   M0  [        U[        5      (       a  [        U[        5      (       a  XC-  nGO/[        U[        [        45      (       a   [        U[        [        45      (       a  XC-  nOô[        U5      (       a  [        U5      (       a  [        XC5      nOÈ[        U5      (       a¸  [        U5      (       a¨  [        S U 5       5      (       a  UR                  U5        GM  U Hw  n[        U5      (       d  [        SU 35      e US   n[        U[        5      (       d  [        SU 35      e XF   n[        U5      (       d  [        S5      e[        X…5      XF'   My     X@U'   GM–     U $ ! [         a  n[        SU 35      UeS nAff = f! [         a    UR                  Xe5         MÅ  f = f)Nrî   r�   c              3  óV   #   • U H   n[        U[        [        [        45      v •  M"     g 7fr)   )Ú
isinstanceÚstrÚintÚfloat)Ú.0Úxs     r.   Ú	<genexpr>Ú#accumulate_delta.<locals>.<genexpr>õ  s!   é € ÐG¹Y¸”:˜a¤#¤s¬EÐ!2×3Ð3ºYùs   ‚')z1Unexpected list delta entry is not a dictionary: z2Expected list delta entry to have an `index` key; z>Unexpected, list delta entry `index` value is not an integer; znot handled yet)Úitemsr«  r¬  r­  r®  r   r£  r   ÚallÚextendÚ	TypeErrorÚKeyErrorrI   r¦  r§  )	Úaccr�   ÚkeyÚdelta_valueÚ	acc_valueÚdelta_entryrî   rþ   Ú	acc_entrys	            r.   r£  r£  ×  så  € Ø!ŸK™KŸMÑˆØ‹>Ø"�‰HÙà‘Hˆ	ØÑØ"�‰HÙð �'‹>˜S F›]Ø"�‰HÙä�i¤×%Ñ%¬*°[Ä#×*FÑ*FØÑ$ŠIÜ˜	¤C¬ <×0Ñ0´ZÀÌcÔSXÈ\×5ZÑ5ZØÑ$‰IÜ�Y×Ñ¤G¨K×$8Ñ$8Ü(¨Ó@‰IÜ�Y×Ñ¤G¨K×$8Ñ$8ô ÑG¹YÓG×GÑGØ× Ñ  Ô-Úã*�Ü˜{×+Ñ+Ü#Ð&WÐXcÐWdÐ$eÓfÐfðtØ'¨Ñ0�Eô " %¬×-Ñ-Ü#Ð&dÐejÐdkÐ$lÓmÐmðPØ )Ñ 0�Iô # 9×-Ñ-Ü'Ð(9Ó:Ð:ä'7¸	Ó'O�IÓ$ñ)  +ð, ˆCŒño *ðr €Jøô%  ó tÜ&Ð)[Ð\gÐ[hÐ'iÓjÐpsÐsûðtûô "ó 9Ø×$Ñ$ U×8ð9ús*   ÅF+Å0GÆ+
G	Æ5GÇG	ÇG+Ç*G+)r  ztuple[type[Exception], ...])r‹   r   rå   zdict[str, RunStep]r  r	  )r‹   r   rf   r  r  z0tuple[Message | None, list[MessageContentDelta]])r¸  r�  r�   r�  r  r�  );Ú
__future__r   r*   Útypesr   Útypingr   r   r   r   r	   r
   r   r   Útyping_extensionsr   r   r   r   Ú_utilsr   r   r   r   Ú_compatr   Ú_httpx2r   Ú_modelsr   Ú
_streamingr   r   Ú
types.betar   Útypes.beta.threadsr   r   r   r   r    r!   r"   r#   Útypes.beta.threads.runsr$   r%   r&   r'   r/   r1   r%  r(  r@  rŽ  r�  rí   rë   r£  r,   r-   r.   Ú<module>rÊ     sù   ðÝ "ã Ý ß [× [Ó [ß SÓ Sç UÓ UÝ !Ý )Ý %ß -Ý .÷	÷ 	ó 	÷ VÓ Uô9÷Fñ FñR !Ð!9ÐAVÑWÐ ô!"˜WÐ%;Ñ<ô !"÷HF ñ F ñR &Ð&CÐKeÑfÐ ô"( 'Ð*EÑ"Fô "(ðJàðð +ðð 
ô	ð:71àð71ð -ð71ð 6ô	71õt:r-   