§
    sŠtj¹  ã                   óN   — d Z ddlZddlZddlmZ ddlmZ  G d„ de¦  «        Z	dS )z*Module containing the SessionThread class.é    Né   )Úqueuec                   ó2   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ ZdS )ÚSessionThreadc                 óf   — || _         || _        |                      ¦   «          || _        || _        d S ©N)Ú_sessionÚ_jobsÚ_create_workerÚ
_responsesÚ_exceptions)ÚselfÚinitialized_sessionÚ	job_queueÚresponse_queueÚexception_queues        ú_/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/requests_toolbelt/threaded/thread.pyÚ__init__zSessionThread.__init__   s7   € à+ˆŒØˆŒ
Ø×ÒÑÔÐØ(ˆŒØ*ˆÔÐÐó    c                 óÊ   — t          j        | j        t          j        ¦   «         ¬¦  «        | _        d| j        _        d| j        _        | j                             ¦   «          d S )N)ÚtargetÚnameTr   )	Ú	threadingÚThreadÚ_make_requestÚuuidÚuuid4Ú_workerÚdaemonÚ_stateÚstart©r   s    r   r   zSessionThread._create_worker   sZ   € Ý Ô'ØÔ%Ý”‘”ð
ñ 
ô 
ˆŒð #ˆŒÔØˆŒÔØŒ×ÒÑÔÐÐÐr   c                 óD  — 	  | j         j        di |¤Ž}| j                             ||f¦  «         n8# t          j        $ r&}| j                             ||f¦  «         Y d }~nd }~ww xY w| j                             ¦   «          d S # | j                             ¦   «          w xY w)N© )	r	   Úrequestr   ÚputÚexcÚRequestExceptionr   r
   Ú	task_done)r   ÚkwargsÚresponseÚes       r   Ú_handle_requestzSessionThread._handle_request   sÅ   € ð	#Ø,�t”}Ô,Ð6Ð6¨vÐ6Ð6ˆHð ŒO×Ò ¨Ð 2Ñ3Ô3Ð3Ð3øõ Ô#ð 	.ð 	.ð 	.ØÔ× Ò  &¨! Ñ-Ô-Ð-Ð-Ð-Ð-Ð-Ð-øøøøð	.øøøð
 ŒJ× Ò Ñ"Ô"Ð"Ð"Ð"øˆDŒJ× Ò Ñ"Ô"Ð"Ð"øøøs,   ‚1 ”B ±A&Á A!ÁB Á!A&Á&B ÂBc                 ó’   — 	 	 | j                              ¦   «         }n# t          j        $ r Y d S w xY w|                      |¦  «         ŒGr   )r
   Ú
get_nowaitr   ÚEmptyr-   )r   r*   s     r   r   zSessionThread._make_request&   s`   € ð	)ðØœ×.Ò.Ñ0Ô0��øÝ”;ð ð ð Ø��ðøøøð × Ò  Ñ(Ô(Ð(ð	)s   ƒ �0¯0c                 ó4   — | j                              ¦   «         S )z*Proxy to the thread's ``is_alive`` method.)r   Úis_aliver"   s    r   r2   zSessionThread.is_alive/   s   € àŒ|×$Ò$Ñ&Ô&Ð&r   c                 ó8   — | j                              ¦   «          dS )z&Join this thread to the master thread.N)r   Újoinr"   s    r   r4   zSessionThread.join3   s   € àŒ×ÒÑÔÐÐÐr   N)	Ú__name__Ú
__module__Ú__qualname__r   r   r-   r   r2   r4   r$   r   r   r   r   
   sn   € € € € € ð+ð +ð +ðð ð ð#ð #ð #ð)ð )ð )ð'ð 'ð 'ðð ð ð ð r   r   )
Ú__doc__r   r   Úrequests.exceptionsÚ
exceptionsr'   Ú_compatr   Úobjectr   r$   r   r   ú<module>r=      sx   ðØ 0Ð 0Ø Ð Ð Ð Ø €€€à !Ð !Ð !Ð !Ð !Ð !à Ð Ð Ð Ð Ð ð+ð +ð +ð +ð +�Fñ +ô +ð +ð +ð +r   