Ë
    ±Œj¹  ã                   óF   — 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	y)z*Module containing the SessionThread class.é    Né   )Úqueuec                   ó0   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zy)ÚSessionThreadc                 ó\   — || _         || _        | j                  «        || _        || _        y ©N)Ú_sessionÚ_jobsÚ_create_workerÚ
_responsesÚ_exceptions)ÚselfÚinitialized_sessionÚ	job_queueÚresponse_queueÚexception_queues        úk/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/requests_toolbelt/threaded/thread.pyÚ__init__zSessionThread.__init__   s+   € à+ˆŒØˆŒ
Ø×ÑÔØ(ˆŒØ*ˆÕó    c                 óì   — t        j                  | j                  t        j                  «       ¬«      | _        d| j
                  _        d| j
                  _        | j
                  j                  «        y )N)ÚtargetÚnameTr   )	Ú	threadingÚThreadÚ_make_requestÚuuidÚuuid4Ú_workerÚdaemonÚ_stateÚstart©r   s    r   r   zSessionThread._create_worker   sP   € Ü ×'Ñ'Ø×%Ñ%Ü—‘“ô
ˆŒð #ˆ�‰ÔØˆ�‰ÔØ�‰×ÑÕr   c                 ód  — 	  | j                   j                  di |¤Ž}| j                  j                  ||f«       | j                  j                  «        y # t        j
                  $ r'}| j                  j                  ||f«       Y d }~ŒPd }~ww xY w# | j                  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¨vÑ6ˆHð �O‰O×Ñ ¨Ð 2Ô3à�J‰J× Ñ Õ"øô ×#Ñ#ò 	.Ø×Ñ× Ñ  &¨! ×-Ñ-ûð	.ûð
 �J‰J× Ñ Õ"ús.   ‚A žB ÁBÁ)BÂB ÂBÂB ÂB/c                 ó�   — 	 	 | j                   j                  «       }| j	                  |«       Œ-# t        j                  $ r Y y w xY wr   )r
   Ú
get_nowaitr   ÚEmptyr-   )r   r*   s     r   r   zSessionThread._make_request&   sI   € ØðØŸ™×.Ñ.Ó0�ð × Ñ  Ô(ð øô —;‘;ò Ùðús   ƒ/ ¯AÁAc                 ó6   — | j                   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                   j                  «        y)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   
   s    „ ò+òò#ò)ò'ór   r   )
Ú__doc__r   r   Úrequests.exceptionsÚ
exceptionsr'   Ú_compatr   Úobjectr   r$   r   r   Ú<module>r=      s    ðÙ 0Û Û å !å ô+�Fõ +r   