o ͷ6i@sddlZddlmZddlmZmZmZmZmZddl m Z m Z m Z defddZ Gd d d eZGd d d ejZGd ddZGdddZdS)N) TracebackType)IteratorCallableListTupleType)URLHeaders TimeoutDictreturnccs dVdS)NrrrX/var/www/hoanhtaovolam_webdjango/env/lib/python3.10/site-packages/httpcore/_sync/base.pyemptys rc@s eZdZdS)NewConnectionRequiredN)__name__ __module__ __qualname__rrrrr src@s(eZdZdZdZdZdZdZdZdZ dS) ConnectionStatez PENDING READY | | ^ v V | ACTIVE | | | | | V | V IDLE-+ FULL | | | V V CLOSED rrN) rrr__doc__PENDINGREADYACTIVEFULLIDLECLOSEDrrrrrsrc@sJeZdZdZ d deededdfddZdeefdd Zd d d Z dS)SyncByteStreamz The base interface for request and response bodies. Concrete implementations should subclass this class, and implement the `\__iter__` method, and optionally the `close` method. Niterator close_funcr cCs|durtn||_||_dSN)rr"r#)selfr"r#rrr__init__/s zSyncByteStream.__init__ccs|jD]}|VqdS)zH Yield bytes representing the request or response body. N)r")r%chunkrrr__iter__5s zSyncByteStream.__iter__cCs|jdur |dSdS)z[ Must be called by the client to indicate that the stream has been closed. N)r#r%rrrclose<s  zSyncByteStream.close)NNr N) rrrrrbytesrr&r(r*rrrrr!'s r!c@seZdZdZ   ddededededede ee ee e eefeff d d Z dd d Z dd dZ   ddeedededdfddZdS)SyncHTTPTransportz The base interface for sending HTTP requests. Concete implementations should subclass this class, and implement the `request` method, and optionally the `close` method. Nmethodurlheadersstreamtimeoutr cCst)ab The interface for sending a single HTTP request, and returning a response. **Parameters:** * **method** - `bytes` - The HTTP method, such as `b'GET'`. * **url** - `Tuple[bytes, bytes, Optional[int], bytes]` - The URL as a 4-tuple of (scheme, host, port, path). * **headers** - `Optional[List[Tuple[bytes, bytes]]]` - Any HTTP headers to send with the request. * **stream** - `Optional[SyncByteStream]` - The body of the HTTP request. * **timeout** - `Optional[Dict[str, Optional[float]]]` - A dictionary of timeout values for I/O operations. ** Returns:** A five-tuple of: * **http_version** - `bytes` - The HTTP version used by the server, such as `b'HTTP/1.1'`. * **status_code** - `int` - The HTTP status code, such as `200`. * **reason_phrase** - `bytes` - Any HTTP reason phrase, such as `b'OK'`. * **headers** - `List[Tuple[bytes, bytes]]` - Any HTTP headers included on the response. * **stream** - `SyncByteStream` - The body of the HTTP response. )NotImplementedError)r%r.r/r0r1r2rrrrequestLs"zSyncHTTPTransport.requestcCsdS)z Close the implementation, which should close any outstanding response streams, and any keep alive connections. Nrr)rrrr*pszSyncHTTPTransport.closecCs|Sr$rr)rrr __enter__vszSyncHTTPTransport.__enter__exc_type exc_value tracebackcCs |dSr$)r*)r%r6r7r8rrr__exit__ys zSyncHTTPTransport.__exit__)NNNr+)r r-)rrrrr,r r r!r rintrr4r*r5r BaseExceptionrr9rrrrr-Ds@  $ r-)enumtypesrtypingrrrrr_typesr r r r ExceptionrIntEnumrr!r-rrrrs