§
    ™ŠtjÌ
  ã                  óz   — d dl mZ d dlZd dlmZ d dlmZmZmZ d dl	m
Z
 d dlmZ d dlmZ  G d„ d	e
¦  «        ZdS )
é    )ÚannotationsN)ÚAsyncIterator)ÚAnyÚLiteralÚcast)ÚAsyncCallbackHandler)Ú	LLMResult)Úoverridec                  ó°   — e Zd ZU dZded<   ded<   edd„¦   «         Zdd
„Zed d„¦   «         Z	ed!d„¦   «         Z
ed"d„¦   «         Zed#d„¦   «         Zd$d„ZdS )%ÚAsyncIteratorCallbackHandlerz0Callback handler that returns an async iterator.zasyncio.Queue[str]Úqueuezasyncio.EventÚdoneÚreturnÚboolc                ó   — dS )zAlways verbose.T© ©Úselfs    úi/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langchain_classic/callbacks/streaming_aiter.pyÚalways_verbosez+AsyncIteratorCallbackHandler.always_verbose   s	   € ð ˆtó    ÚNonec                óf   — t          j        ¦   «         | _        t          j        ¦   «         | _        dS )z)Instantiate AsyncIteratorCallbackHandler.N)ÚasyncioÚQueuer   ÚEventr   r   s    r   Ú__init__z%AsyncIteratorCallbackHandler.__init__   s    € å”]‘_”_ˆŒ
Ý”M‘O”OˆŒ	ˆ	ˆ	r   Ú
serializedúdict[str, Any]Úpromptsú	list[str]Úkwargsr   c              ‹  ó<   K  — | j                              ¦   «          d S ©N)r   Úclear)r   r   r    r"   s       r   Úon_llm_startz)AsyncIteratorCallbackHandler.on_llm_start   s    è è € ð 	Œ	�ŠÑÔÐÐÐr   Útokenú str | list[str | dict[str, Any]]c              ‹  óš   K  — t          |t          ¦  «        r|nt          |¦  «        }|dk    r| j                             |¦  «         d S d S )NÚ )Ú
isinstanceÚstrr   Ú
put_nowait)r   r'   r"   Ú	token_strs       r   Úon_llm_new_tokenz-AsyncIteratorCallbackHandler.on_llm_new_token)   sR   è è € õ (¨­sÑ3Ô3ÐC�E�E½¸U¹¼ˆ	Ø˜Š?ˆ?ØŒJ×!Ò! )Ñ,Ô,Ð,Ð,Ð,ð ˆ?r   Úresponser	   c              ‹  ó<   K  — | j                              ¦   «          d S r$   ©r   Úset)r   r0   r"   s      r   Ú
on_llm_endz'AsyncIteratorCallbackHandler.on_llm_end1   ó   è è € àŒ	�Š‰Œˆˆˆr   ÚerrorÚBaseExceptionc              ‹  ó<   K  — | j                              ¦   «          d S r$   r2   )r   r6   r"   s      r   Úon_llm_errorz)AsyncIteratorCallbackHandler.on_llm_error5   r5   r   úAsyncIterator[str]c               ó¢  K  — | j                              ¦   «         r| j                             ¦   «         �st	          j        t	          j        | j                              ¦   «         ¦  «        t	          j        | j                             ¦   «         ¦  «        gt          j        ¬¦  «        ƒ d{V —†\  }}|r&| 	                    ¦   «          
                    ¦   «          t          d| 	                    ¦   «                              ¦   «         ¦  «        }|du rdS |W V — | j                              ¦   «         ¯ý| j                             ¦   «         �¯dS dS )z)Asynchronous iterator that yields tokens.)Úreturn_whenNzstr | Literal[True]T)r   Úemptyr   Úis_setr   ÚwaitÚensure_futureÚgetÚFIRST_COMPLETEDÚpopÚcancelr   Úresult)r   r   ÚotherÚtoken_or_dones       r   Úaiterz"AsyncIteratorCallbackHandler.aiter;   s\  è è € à”*×"Ò"Ñ$Ô$ð 	 ¨D¬I×,<Ò,<Ñ,>Ô,>ñ 	 õ !(¤õ Ô)¨$¬*¯.ª.Ñ*:Ô*:Ñ;Ô;ÝÔ)¨$¬)¯.ª.Ñ*:Ô*:Ñ;Ô;ð	õ $Ô3ð!ñ !ô !ð ð ð ð ð ð ‰KˆD�%ð ð %Ø—	’	‘”×"Ò"Ñ$Ô$Ð$õ !Ð!6¸¿º¹
¼
×8IÒ8IÑ8KÔ8KÑLÔLˆMð  Ð$Ð$Ø�ð  ÐÐÐÐð3 ”*×"Ò"Ñ$Ô$ð 	 ¨D¬I×,<Ò,<Ñ,>Ô,>ñ 	 ð 	 ð 	 ð 	 ð 	 r   N)r   r   )r   r   )r   r   r    r!   r"   r   r   r   )r'   r(   r"   r   r   r   )r0   r	   r"   r   r   r   )r6   r7   r"   r   r   r   )r   r:   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__Úpropertyr   r   r
   r&   r/   r4   r9   rH   r   r   r   r   r      sú   € € € € € € Ø:Ð:àÐÐÑàÐÐÑàðð ð ñ „Xðð$ð $ð $ð $ð
 ðð ð ñ „Xðð ð-ð -ð -ñ „Xð-ð ðð ð ñ „Xðð ðð ð ñ „Xðð
 ð  ð  ð  ð  ð  r   r   )Ú
__future__r   r   Úcollections.abcr   Útypingr   r   r   Úlangchain_core.callbacksr   Úlangchain_core.outputsr	   Útyping_extensionsr
   r   r   r   r   ú<module>rU      sÅ   ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø )Ð )Ð )Ð )Ð )Ð )Ø %Ð %Ð %Ð %Ð %Ð %Ð %Ð %Ð %Ð %à 9Ð 9Ð 9Ð 9Ð 9Ð 9Ø ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø &Ð &Ð &Ð &Ð &Ð &ð
H ð H ð H ð H ð H Ð#7ñ H ô H ð H ð H ð H r   