hddlmZmZddlZddlZddlmZddlmZddl m Z ddl m Z m Z erddlmZGd d eeZGd d eZGd deZdZy))print_functionunicode_literalsN)Queue) TYPE_CHECKING)AuthSrv)HMaccasPebkac)HttpSrvc eZdZdfd ZxZS)ExceptionalQueuectt| ||}t|tr |ddk(r|ddk(r t |dd|d|S)Nr exceptionrpebkac)superr get isinstancelistr )selfblocktimeoutrv __class__s J/jellyfin/media/venv/lib/python3.12/site-packages/copyparty/broker_util.pyrzExceptionalQueue.getsW #T .ug > b$ !u #a5H$ "QR&/)Q%K )TN)__name__ __module__ __qualname__r __classcell__)rs@rr r s   rr ceZdZdZdZdZy) NotExQueuezD BrokerThr uses this instead of ExceptionalQueue; 7x faster c||_yNr)rrs r__init__zNotExQueue.__init__$s rc|jSr$r%rs rrzNotExQueue.get's wwrN)rrr__doc__r&rrrr"r"srr"c"eZdZdZdZdZdZy) BrokerCliz helps mypy understand httpsrv.broker but still fails a few levels deeper, for example resolving httpconn.* in httpcli -- see lines tagged #mypy404 cyr$r*r(s rr&zBrokerCli.__init__7 rctdS)Nr)r rdestargss raskz BrokerCli.ask:s ""rcyr$r*r0s rsayz BrokerCli.say=r.rN)rrrr)r&r3r5r*rrr,r,+s # rr,c ||S#t$r&}|sdd|jt|gcYd}~Sd}~wt$r}|sdd|gcYd}~Sd}~wwxYw)Nrrstack)r codestr Exception) want_retvalfuncr2exs rtry_execr>AsZ *T{ 9 XrwwB88 * Wb)) *s( A1A AA A A) __future__rrargparse tracebackqueuerr&rauthsrvrutilr r httpsrvr objectr r"r,r>r*rrrGsK7#!  uf     ,*r