Directory:~$ /proc/self/root/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/

Upload File

[Home] [System Details] [Kill Me]

�
ӵ
Yc@sWdZd
dl
Z
d
dlZd
dljZddlmZ
def
d��YZ	dS(s*Module
containing the SessionThread
class.i����Ni(
tqueuet
SessionThreadc
Bs>eZ
d�Zd
�Zd�Zd�Zd�Zd�ZRS(cCs2|
|_||_
|j�
||_||_dS(
N(t_sessiont_jobst_create_workert
_responsest_exceptions(tselftinitialized_sessiont	job_queuetresponse_queuetexception_queue((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyt__init__s
	
	


	
c

CsMtj
d
|jdtj��|_t|j_d|j_|jj	�
dS(Nttargettnamei(
t	threadingtThreadt
_make_requesttuuidtuuid4t_workertTruetdaemont_statetstart(
R((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyRs
	
	


cCstz_y|jj
|
�}Wn,tjk
rG
}
|jj|
|f�

nX|jj|
|f�

Wd|jj�
XdS(
N(	RtrequesttexctRequestExceptionRtputRRt	task_done(Rtkwargstresponset
e((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyt_handle_requests



c
CsIxBtrDy|j
j�}
Wntjk
r3


Pn
X|j|
�

qWdS(
N(RRt
get_nowaitRtEmptyR!(RR((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR&s
	



c


Cs
|jj
�S(
s*Proxy
to the thread's ``is_alive``
method.(Rtis_alive(
R((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR$/sc


Cs|jj
�
d
S(s&Join
this thread to the master
thread.N(Rtjoin(
R((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR%3s(t__name__t
__module__RRR!RR$R%(((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR

s
				
			(
t__doc__RRtrequests.exceptionst
exceptionsRt_compatRtobjectR
(((sE/usr/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyt<module>
s