a ù!f¹ã@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 úb/var/www/html/python-backend/venv/lib/python3.9/site-packages/requests_toolbelt/threaded/thread.pyÚ__init__ s zSessionThread.__init__cCs4tj|jt ¡d|_d|j_d|j_|j ¡dS)N)ÚtargetÚnameTr) Ú threadingÚThreadÚ _make_requestÚuuidÚuuid4Ú_workerÚdaemonÚ_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) rÚrequestÚexcÚRequestExceptionr Úputr rÚ task_done)r ÚkwargsÚresponseÚer r r Ú_handle_requests &zSessionThread._handle_requestcCs8z|j ¡}Wntjy&Yq4Yn0| |¡qdSr)rÚ get_nowaitrÚEmptyr#)r r r 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 r'3szSessionThread.joinN) Ú__name__Ú __module__Ú __qualname__rrr#rr&r'r r r r r s    r) Ú__doc__rrZrequests.exceptionsÚ exceptionsrZ_compatrÚobjectrr r r r Ús