Ë Ç5hgãóz—ddlmZddlZddlZddlmZmZmZmZm Z m Z m Z m Z m Z mZGd„d«ZGd„de«Zy) é)Ú annotationsNé) ÚURLÚ ExtensionsÚ HeaderTypesÚOriginÚRequestÚResponseÚ enforce_bytesÚenforce_headersÚ enforce_urlÚinclude_request_headerscó‚—eZdZddddœ dd„Zej ddddœ dd„«Zdd„Zy) ÚAsyncRequestInterfaceN)ÚheadersÚcontentÚ extensionscƒótK—t|d¬«}t|d¬«}t|d¬«}t|||¬«}t |||||¬«}|j |«ƒd{–—†} |j «ƒd{–—†|j«ƒd{–—†|S7Œ77Œ 7Œ #|j«ƒd{–—†7wxYw­w©NÚmethod)ÚnameÚurlr)rr)rrrrr)r r r rr Úhandle_async_requestÚareadÚaclose©ÚselfrrrrrÚrequestÚresponses úh/var/www/dev.core.comfenalco.cic-ware.com/crm/lib/python3.12/site-packages/httpcore/_async/interfaces.pyrzAsyncRequestInterface.requests±èø€ô˜v¨HÔ5ˆÜ˜# EÔ*ˆÜ! '° Ô:ˆô*¨'°sÀGÔLˆäØØØØØ!ô  ˆð×2Ñ2°7Ó;×;ˆð $Ø—.‘.Ó"× "Ð "à—/‘/Ó#× #Ð #؈ð <øà "øà #ù(—/‘/Ó#× #Ò #üsZ‚AB8ÁBÁB8Á"BÁ5BÁ6BÁ:B8 BÂB8ÂBÂB8ÂB5Â.B1Â/B5Â5B8cóHK—t|d¬«}t|d¬«}t|d¬«}t|||¬«}t |||||¬«}|j |«ƒd{–—†} |­–—|j «ƒd{–—†y7Œ#7Œ#|j «ƒd{–—†7wxYw­wr)r r r rr rrrs r ÚstreamzAsyncRequestInterface.stream4sŸèø€ô˜v¨HÔ5ˆÜ˜# EÔ*ˆÜ! '° Ô:ˆô*¨'°sÀGÔLˆäØØØØØ!ô  ˆð×2Ñ2°7Ó;×;ˆð $Ø‹Nà—/‘/Ó#× #Ñ #ð <øð $ù(—/‘/Ó#× #Ò #üsH‚AB"ÁBÁB"Á"BÁ'B"Á:BÁ;B"ÂB"ÂBÂBÂBÂB"cƒóK—t«‚­w©N©ÚNotImplementedError)rrs r rz*AsyncRequestInterface.handle_async_requestSóèø€Ü!Ó#Ð#ùó‚ ) rú bytes | strrúURL | bytes | strrrrú*bytes | typing.AsyncIterator[bytes] | NonerúExtensions | NoneÚreturnr ) rr)rr*rrrr+rr,r-ztyping.AsyncIterator[Response])rr r-r )Ú__name__Ú __module__Ú __qualname__rÚ contextlibÚasynccontextmanagerr"r©ór rrs°„ð $Ø>BØ(,ñàðððð ð ð <ð ð&ðð óð>×#Ñ#ð $Ø>BØ(,ñ$àð$ðð$ð ð $ð <ð $ð&ð$ð (ò$ó$ð$ô<$r4rcóD—eZdZd d„Zd d„Zd d„Zd d„Zd d„Zd d„Zd d„Z y) ÚAsyncConnectionInterfacecƒóK—t«‚­wr$r%©rs r rzAsyncConnectionInterface.acloseXr'r(có—t«‚r$r%r8s r ÚinfozAsyncConnectionInterface.info[ó €Ü!Ó#Ð#r4có—t«‚r$r%)rÚorigins r Úcan_handle_requestz+AsyncConnectionInterface.can_handle_request^r;r4có—t«‚)aÖ Return `True` if the connection is currently able to accept an outgoing request. An HTTP/1.1 connection will only be available if it is currently idle. An HTTP/2 connection will be available so long as the stream ID space is not yet exhausted, and the connection is not in an error state. While the connection is being established we may not yet know if it is going to result in an HTTP/1.1 or HTTP/2 connection. The connection should be treated as being available, but might ultimately raise `NewConnectionRequired` required exceptions if multiple requests are attempted over a connection that ends up being established as HTTP/1.1. r%r8s r Ú is_availablez%AsyncConnectionInterface.is_availableas €ô "Ó#Ð#r4có—t«‚)zî Return `True` if the connection is in a state where it should be closed. This either means that the connection is idle and it has passed the expiry time on its keep-alive, or that server has sent an EOF. r%r8s r Ú has_expiredz$AsyncConnectionInterface.has_expiredsó €ô"Ó#Ð#r4có—t«‚)zD Return `True` if the connection is currently idle. r%r8s r Úis_idlez AsyncConnectionInterface.is_idle|s €ô"Ó#Ð#r4có—t«‚)zÀ Return `True` if the connection has been closed. Used when a response is closed to determine if the connection may be returned to the connection pool or not. r%r8s r Ú is_closedz"AsyncConnectionInterface.is_closed‚rCr4N)r-ÚNone)r-Ústr)r=rr-Úbool)r-rJ) r.r/r0rr:r>r@rBrErGr3r4r r6r6Ws%„ó$ó$ó$ó$ó$$ó$ô $r4r6)Ú __future__rr1ÚtypingÚ_modelsrrrrr r r r r rrr6r3r4r úrNs7ðÝ"ãÛ ÷ ÷ ÷ ÷@$ñ@$ôF2$Ð4õ2$r4