ó
    úÞ j¹  ã                   óF   • S r SSKrSSKrSSKJr  SSKJr   " S S\5      r	g)z*Module containing the SessionThread class.é    Né   )Úqueuec                   ó8   • \ rS rSrS rS rS rS rS rS r	Sr
g	)
ÚSessionThreadé
   c                 óT   • Xl         X l        U R                  5         X0l        X@l        g ©N)Ú_sessionÚ_jobsÚ_create_workerÚ
_responsesÚ_exceptions)ÚselfÚinitialized_sessionÚ	job_queueÚresponse_queueÚexception_queues        Ú[/var/www/html/gaurav/venv/lib/python3.13/site-packages/requests_toolbelt/threaded/thread.pyÚ__init__ÚSessionThread.__init__   s#   € à+ŒØŒ
Ø×ÑÔØ(ŒØ*Õó    c                 óê   • [         R                  " U R                  [        R                  " 5       S9U l        SU R
                  l        SU R
                  l        U R
                  R                  5         g )N)ÚtargetÚnameTr   )	Ú	threadingÚThreadÚ_make_requestÚuuidÚuuid4Ú_workerÚdaemonÚ_stateÚstart©r   s    r   r   ÚSessionThread._create_worker   sP   € Ü ×'Ò'Ø×%Ñ%Ü—’“ñ
ˆŒð #ˆ�‰ÔØˆ�‰ÔØ�‰×ÑÕr   c                 ób  •  U R                   R                  " S0 UD6nU R                  R                  X45        U R                  R                  5         g ! [        R
                   a&  nU R                  R                  X45         S nANPS nAff = f! U R                  R                  5         f = f)N© )	r
   Úrequestr   ÚputÚexcÚRequestExceptionr   r   Ú	task_done)r   ÚkwargsÚresponseÚes       r   Ú_handle_requestÚSessionThread._handle_request   s‰   € ð	#Ø—}‘}×,Ò,Ñ6¨vÑ6ˆHð �O‰O×Ñ Ð 2Ô3à�J‰J× Ñ Õ"øô ×#Ñ#ó 	.Ø×Ñ× Ñ  & ×-Ñ-ûð	.ûð
 �J‰J× Ñ Õ"ús.   ‚A žB ÁBÁ)B
ÂB Â
BÂB ÂB.c                 ó”   •   U R                   R                  5       nU R	                  U5        M.  ! [        R                   a     g f = fr	   )r   Ú
get_nowaitr   ÚEmptyr0   )r   r-   s     r   r   ÚSessionThread._make_request&   sI   € ØðØŸ™×.Ñ.Ó0�ð × Ñ  Ô(ñ øô —;‘;ó Ùðús   ƒ0 °AÁAc                 ó6   • U R                   R                  5       $ )z*Proxy to the thread's ``is_alive`` method.)r    Úis_aliver$   s    r   r7   ÚSessionThread.is_alive/   s   € à�|‰|×$Ñ$Ó&Ð&r   c                 ó8   • U R                   R                  5         g)z&Join this thread to the master thread.N)r    Újoinr$   s    r   r:   ÚSessionThread.join3   s   € à�‰×ÑÕr   )r   r   r   r
   r    N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r   r0   r   r7   r:   Ú__static_attributes__r'   r   r   r   r   
   s    † ò+òò#ò)ò'õr   r   )
Ú__doc__r   r   Úrequests.exceptionsÚ
exceptionsr*   Ú_compatr   Úobjectr   r'   r   r   Ú<module>rF      s    ðÙ 0Û Û å !å ô+�Fõ +r   