a ÇË€X¹ã@s@dZddlZddlZddlmZddlmZGdd„deƒZ dS)z*Module containing the SessionThread class.éNé)Úqueuec@s<eZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd S)Ú SessionThreadcCs$||_||_| ¡||_||_dS©N)Ú_sessionÚ_jobsÚ_create_workerÚ _responsesÚ _exceptions)ÚselfZinitialized_sessionZ job_queueZresponse_queueZexception_queue©r úC/usr/lib/python3/dist-packages/requests_toolbelt/threaded/thread.pyÚ__init__ s zSessionThread.__init__cCs4tj|jt ¡d|_d|j_d|j_|j ¡dS)N)ÚtargetÚnameTr) Ú threadingZThreadÚ _make_requestÚuuidZuuid4Ú_workerZdaemonZ_stateÚstart©r r r r rsþzSessionThread._create_workerc Cs~zlz|jjfi|¤Ž}Wn6tjyN}z|j ||f¡WYd}~nd}~00|j ||f¡W|j ¡n |j ¡0dSr) rZrequestÚexcZRequestExceptionr Zputr rZ task_done)r ÚkwargsZresponseÚer r r Ú_handle_requests &zSessionThread._handle_requestcCs8z|j ¡}Wntjy&Yq4Yn0| |¡qdSr)rZ get_nowaitrZEmptyr)r rr r r r&s  zSessionThread._make_requestcCs |j ¡S)z*Proxy to the thread's ``is_alive`` method.)rÚis_aliverr r r r/szSessionThread.is_alivecCs|j ¡dS)z&Join this thread to the master thread.N)rÚjoinrr r r r3szSessionThread.joinN) Ú__name__Ú __module__Ú __qualname__rrrrrrr r r r r s    r) Ú__doc__rrZrequests.exceptionsÚ exceptionsrZ_compatrÚobjectrr r r r Ús