ó o€ \c@sWdZddlZddlZddljZddlmZdefd„ƒYZ dS(s*Module containing the SessionThread class.iÿÿÿÿNi(tqueuet SessionThreadcBs>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cCs2||_||_|jƒ||_||_dS(N(t_sessiont_jobst_create_workert _responsest _exceptions(tselftinitialized_sessiont job_queuetresponse_queuetexception_queue((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyt__init__ s     cCsMtjd|jdtjƒƒ|_t|j_d|j_|jj ƒdS(Nttargettnamei( t threadingtThreadt _make_requesttuuidtuuid4t_workertTruetdaemont_statetstart(R((sV/data/av2000/b2b/venv/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(Rtkwargstresponsete((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyt_handle_requestscCsIxBtrDy|jjƒ}Wntjk r3PnX|j|ƒqWdS(N(RRt get_nowaitRtEmptyR!(RR((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR&s  cCs |jjƒS(s*Proxy to the thread's ``is_alive`` method.(Rtis_alive(R((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR$/scCs|jjƒdS(s&Join this thread to the master thread.N(Rtjoin(R((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR%3s(t__name__t __module__R RR!RR$R%(((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyR s   ( t__doc__RRtrequests.exceptionst exceptionsRt_compatRtobjectR(((sV/data/av2000/b2b/venv/lib/python2.7/site-packages/requests_toolbelt/threaded/thread.pyts