File: //usr/lib/python3/dist-packages/requests_toolbelt/threaded/__pycache__/thread.cpython-310.pyc
o
�ˀX� � @ s@ d Z ddlZddlZddlmZ ddlmZ G dd� de�Z dS )z*Module containing the SessionThread class.� N� )�queuec @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�
SessionThreadc C s$ || _ || _| �� || _|| _d S �N)�_session�_jobs�_create_worker�
_responses� _exceptions)�self�initialized_session� job_queue�response_queue�exception_queue� r �C/usr/lib/python3/dist-packages/requests_toolbelt/threaded/thread.py�__init__ s
zSessionThread.__init__c C s4 t j| jt�� d�| _d| j_d| j_| j�� d S )N)�target�nameTr ) � threading�Thread�
_make_request�uuid�uuid4�_worker�daemon�_state�start�r r r r r s �z SessionThread._create_workerc
C s� z?z | j jdi |��}W n tjy' } z| j�||f� W Y d }~nd }~ww | j�||f� W | j�� d S W | j�� d S | j�� w )Nr ) r �request�exc�RequestExceptionr
�putr r � task_done)r �kwargs�response�er r r �_handle_request s ���z SessionThread._handle_requestc C s4 z| j �� }W n tjy Y d S w | �|� qr )r �
get_nowaitr �Emptyr' )r r$ r r r r & s �
�zSessionThread._make_requestc C s
| j �� S )z*Proxy to the thread's ``is_alive`` method.)r �is_aliver r r r r* / s
zSessionThread.is_alivec C s | j �� dS )z&Join this thread to the master thread.N)r �joinr r r r r+ 3 s zSessionThread.joinN) �__name__�
__module__� __qualname__r r r' r r* r+ r r r r r
s
r )
�__doc__r r �requests.exceptions�
exceptionsr �_compatr �objectr r r r r �<module> s