o V h@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)selfinitialized_session job_queueresponse_queueexception_queueru/var/www/html/construction_image-detection-poc/venv/lib/python3.10/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 rrrrszSessionThread._create_workerc Csz?z |jjdi|}Wntjy'}z|j||fWYd}~nd}~ww|j||fW|jdSW|jdS|jw)Nr) rrequestexcRequestExceptionr putr r task_done)r kwargsresponseerrr_handle_requestszSessionThread._handle_requestcCs4 z|j}Wn tjyYdSw||qr)r get_nowaitrEmptyr')r r$rrrr&s zSessionThread._make_requestcCs |jS)z*Proxy to the thread's ``is_alive`` method.)ris_aliverrrrr*/s zSessionThread.is_alivecCs|jdS)z&Join this thread to the master thread.N)rjoinrrrrr+3szSessionThread.joinN) __name__ __module__ __qualname__rrr'rr*r+rrrrr s   r) __doc__rrrequests.exceptions exceptionsr _compatrobjectrrrrrs