U Zj@s@dZddlZddlZddlmZddlmZGdddeZ dS)z*Module containing the SessionThread class.N)queuec@s<eZdZddZddZddZddZd d Zd d Zd S) SessionThreadcCs$||_||_|||_||_dSN)_session_jobs_create_worker _responses _exceptions)selfZinitialized_sessionZ job_queueZresponse_queueZexception_queuer d/var/www/html/TRUCKING_PROJECT/venv/lib/python3.8/site-packages/requests_toolbelt/threaded/thread.py__init__ s zSessionThread.__init__cCs4tj|jtd|_d|j_d|j_|jdS)N)targetnameTr) threadingThread _make_requestuuiduuid4_workerdaemon_statestartr r r r rszSessionThread._create_workerc Csnz\z|jjf|}Wn4tjk rH}z|j||fW5d}~XYnX|j||fW5|jXdSr) r task_donerrequestexcRequestExceptionr putr )r kwargsresponseer r r _handle_requests "zSessionThread._handle_requestcCs:z|j}Wntjk r(Yq6YnX||qdSr)r get_nowaitrEmptyr#)r r r r r r&s  zSessionThread._make_requestcCs |jS)z*Proxy to the thread's ``is_alive`` method.)ris_aliverr r r r&/szSessionThread.is_alivecCs|jdS)z&Join this thread to the master thread.N)rjoinrr r r r'3szSessionThread.joinN) __name__ __module__ __qualname__rrr#rr&r'r r r r r s    r) __doc__rrZrequests.exceptions exceptionsrZ_compatrobjectrr r r r s