o ͷ6i @spddlmZddlmZddlmZmZddlmZGdddZ Gdd d Z Gd d d Z Gd d d Z dS)) SSLContext) TracebackType)OptionalType) TimeoutDictc@s|eZdZdZdefddZdedededdfdd Z d e dedefd d Z d ededdfddZ dddZ defddZdS)AsyncSocketStreamz A socket stream with read/write operations. Abstracts away any asyncio-specific interfaces into a more generic base class, that we can use with alternate backends, or for stand-alone test cases. returncCtNNotImplementedErrorselfr\/var/www/hoanhtaovolam_webdjango/env/lib/python3.10/site-packages/httpcore/_backends/base.pyget_http_versionz"AsyncSocketStream.get_http_versionhostname ssl_contexttimeoutctr r )rrrrrrr start_tlsszAsyncSocketStream.start_tlsncrr r )rrrrrrreadzAsyncSocketStream.readdataNcrr r )rrrrrrwriterzAsyncSocketStream.writecrr r rrrracloserzAsyncSocketStream.aclosecCr r r rrrris_connection_dropped rz'AsyncSocketStream.is_connection_droppedr N)__name__ __module__ __qualname____doc__strrbytesrrrintrrrboolrrrrrrs   rc @sTeZdZdZdddZ   ddeedededdfd d Zdd d Z dd dZ dS) AsyncLockz1 An abstract interface for Lock classes. r Ncs|IdHdSr )acquirerrrr __aenter__)szAsyncLock.__aenter__exc_type exc_value tracebackcs|dSr )release)rr,r-r.rrr __aexit__,s zAsyncLock.__aexit__cCr r r rrrrr/4rzAsyncLock.releasecrr r rrrrr*7rzAsyncLock.acquirer )NNN) r!r"r#r$r+r BaseExceptionrr0r/r*rrrrr)$s"  r)c@s.eZdZdZd deddfddZd ddZdS) AsyncSemaphorezj An abstract interface for Semaphore classes. Abstracts away any asyncio-specific interfaces. Nrr crr r )rrrrrr*ArzAsyncSemaphore.acquirecCr r r rrrrr/DrzAsyncSemaphore.releaser r )r!r"r#r$floatr*r/rrrrr2;sr2c @s`eZdZdededeededef ddZ de fdd Z d ed e de fd d ZdefddZdS) AsyncBackendrportrrr crr r )rrr5rrrrropen_tcp_streamIszAsyncBackend.open_tcp_streamcCr r r rrrr create_lockRrzAsyncBackend.create_lock max_value exc_classcCr r r )rr8r9rrrcreate_semaphoreUrzAsyncBackend.create_semaphorecCr r r rrrrtimeXrzAsyncBackend.timeN)r!r"r#r&r'rrrrr6r)r7typer2r:r3r;rrrrr4Hs  r4N) sslrtypesrtypingrr_typesrrr)r2r4rrrrs