Ë
    ´Œj‡	  ã                  ój   — d dl mZ d dlZd dlmZ d dlmZmZmZm	Z	 d dl
mZ d dlmZ  G d„ de«      Zy)	é    )ÚannotationsN)ÚAsyncIterator)ÚAnyÚLiteralÚUnionÚcast)ÚAsyncCallbackHandler)Ú	LLMResultc                  óx   — e Zd ZU dZded<   ded<   edd„«       Zdd„Z	 	 	 	 	 	 	 	 dd„Zdd	„Z	dd
„Z
dd„Zdd„Zy)ÚAsyncIteratorCallbackHandlerz0Callback handler that returns an async iterator.zasyncio.Queue[str]Úqueuezasyncio.EventÚdonec                 ó   — y)NT© ©Úselfs    úm/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langchain/callbacks/streaming_aiter.pyÚalways_verbosez+AsyncIteratorCallbackHandler.always_verbose   s   € àó    c                óh   — t        j                  «       | _        t        j                  «       | _        y ©N)ÚasyncioÚQueuer   ÚEventr   r   s    r   Ú__init__z%AsyncIteratorCallbackHandler.__init__   s   € Ü—]‘]“_ˆŒ
Ü—M‘M“Oˆ�	r   c              ‹  ó@   K  — | j                   j                  «        y ­wr   )r   Úclear)r   Ú
serializedÚpromptsÚkwargss       r   Úon_llm_startz)AsyncIteratorCallbackHandler.on_llm_start   s   è ø€ ð 	�	‰	�‰Õùó   ‚c              ‹  óT   K  — |�"|dk7  r| j                   j                  |«       y y y ­w)NÚ )r   Ú
put_nowait)r   Útokenr    s      r   Úon_llm_new_tokenz-AsyncIteratorCallbackHandler.on_llm_new_token%   s,   è ø€ ØÐ ¨"¢Ø�J‰J×!Ñ! %Õ(ð "-Ðùs   ‚&(c              ‹  ó@   K  — | j                   j                  «        y ­wr   ©r   Úset)r   Úresponser    s      r   Ú
on_llm_endz'AsyncIteratorCallbackHandler.on_llm_end)   ó   è ø€ Ø�	‰	�‰�ùr"   c              ‹  ó@   K  — | j                   j                  «        y ­wr   r)   )r   Úerrorr    s      r   Úon_llm_errorz)AsyncIteratorCallbackHandler.on_llm_error,   r-   r"   c               óÈ  K  — | j                   j                  «       r| j                  j                  «       �s't	        j
                  t	        j                  | j                   j                  «       «      t	        j                  | j                  j                  «       «      gt        j                  ¬«      ƒ d {  –—† \  }}|r|j                  «       j                  «        t        t        t        t        d   f   |j                  «       j                  «       «      }|du ry |­–— | j                   j                  «       s�Œ
| j                  j                  «       s�Œ&y y 7 Œ§­w)N)Úreturn_whenT)r   Úemptyr   Úis_setr   ÚwaitÚensure_futureÚgetÚFIRST_COMPLETEDÚpopÚcancelr   r   Ústrr   Úresult)r   r   ÚotherÚtoken_or_dones       r   Úaiterz"AsyncIteratorCallbackHandler.aiter1   s  è ø€ Ø—*‘*×"Ñ"Ô$¨D¯I©I×,<Ñ,<Õ,>ô !(§¡ô ×)Ñ)¨$¯*©*¯.©.Ó*:Ó;Ü×)Ñ)¨$¯)©)¯.©.Ó*:Ó;ð	ô $×3Ñ3ô!÷ ‰KˆD�%ñ Ø—	‘	“×"Ñ"Ô$ô !¤¤s¬G°D©MÐ'9Ñ!:¸D¿H¹H»J×<MÑ<MÓ<OÓPˆMð  Ñ$Øð  Óð3 —*‘*×"Ñ"Ö$¨D¯I©I×,<Ñ,<×,>Ð,>ðús   ‚B6E"Â8E Â9BE"ÅE"ÅE"N)ÚreturnÚbool)r@   ÚNone)r   zdict[str, Any]r   z	list[str]r    r   r@   rB   )r&   r;   r    r   r@   rB   )r+   r
   r    r   r@   rB   )r/   ÚBaseExceptionr    r   r@   rB   )r@   zAsyncIterator[str])Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__Úpropertyr   r   r!   r'   r,   r0   r?   r   r   r   r   r      sg   … Ù:àÓà
Óàòó ðó$ðà"ðð ðð ð	ð
 
óó)óóô
 r   r   )Ú
__future__r   r   Úcollections.abcr   Útypingr   r   r   r   Úlangchain_core.callbacksr	   Úlangchain_core.outputsr
   r   r   r   r   Ú<module>rO      s'   ðÝ "ã Ý )ß ,Ó ,å 9Ý ,ô
> Ð#7õ > r   