o #`^h:@s8dZddlmZmZGdddeZGdddeZdS)z)linebot.aiohttp_async_http_client module.)AsyncHttpClientAsyncHttpResponsecsNeZdZdZejffdd Zd ddZd ddZd d d Z d d d Z Z S)AiohttpAsyncHttpClientz#HttpClient implemented by requests.cstt||||_dS)a7__init__ method. :param timeout: (optional) How long to wait for the server to send data before giving up, as a float, or a (connect timeout, read timeout) float tuple. Default is :py:attr:`DEFAULT_TIMEOUT` :type timeout: float | tuple(float, float) N)superr__init__session)selfrtimeout __class___/home/air/shanriGPT/back/venv/lib/python3.10/site-packages/linebot/aiohttp_async_http_client.pyrs zAiohttpAsyncHttpClient.__init__Nc2|dur|j}|jj||||dIdH}t|S)a&GET request. :param str url: Request url :param dict headers: (optional) Request headers :param dict params: (optional) Request query parameter :param timeout: (optional), How long to wait for the server to send data before giving up, as a float, or a (connect timeout, read timeout) float tuple. Default is :py:attr:`self.timeout` :type timeout: float | tuple(float, float) :rtype: :py:class:`AsyncHttpResponse` :return: AsyncHttpResponse instance N)headersparamsr )r rgetAiohttpAsyncHttpResponse)rurlrrr responser r r r# zAiohttpAsyncHttpClient.getcr)aQPOST request. :param str url: Request url :param dict headers: (optional) Request headers :param data: (optional) Dictionary, bytes, or file-like object to send in the body :param timeout: (optional), How long to wait for the server to send data before giving up, as a float, or a (connect timeout, read timeout) float tuple. Default is :py:attr:`self.timeout` :type timeout: float | tuple(float, float) :rtype: :py:class:`AiohttpAsyncHttpResponse` :return: AiohttpAsyncHttpResponse instance Nrdatar )r rpostrrrrrr rr r r r7rzAiohttpAsyncHttpClient.postcr)aSDELETE request. :param str url: Request url :param dict headers: (optional) Request headers :param data: (optional) Dictionary, bytes, or file-like object to send in the body :param timeout: (optional), How long to wait for the server to send data before giving up, as a float, or a (connect timeout, read timeout) float tuple. Default is :py:attr:`self.timeout` :type timeout: float | tuple(float, float) :rtype: :py:class:`AiohttpAsyncHttpResponse` :return: AiohttpAsyncHttpResponse instance Nr)r rdeleterrr r r rKrzAiohttpAsyncHttpClient.deletecr)aPPUT request. :param str url: Request url :param dict headers: (optional) Request headers :param data: (optional) Dictionary, bytes, or file-like object to send in the body :param timeout: (optional), How long to wait for the server to send data before giving up, as a float, or a (connect timeout, read timeout) float tuple. Default is :py:attr:`self.timeout` :type timeout: float | tuple(float, float) :rtype: :py:class:`AiohttpAsyncHttpResponse` :return: AiohttpAsyncHttpResponse instance Nr)r rputrrr r r r_rzAiohttpAsyncHttpClient.put)NNN) __name__ __module__ __qualname____doc__rDEFAULT_TIMEOUTrrrrr __classcell__r r r r rs  rc@s^eZdZdZddZeddZeddZedd Zed d Z ed d Z dddZ dS)rz4AsyncHttpResponse implemented by aiohttp's response.cCs ||_dS)zF__init__ method. :param response: aiohttp's response N)r)rrr r r rws z!AiohttpAsyncHttpResponse.__init__cC|jjS)zGet status code.)rstatusrr r r status_code~sz$AiohttpAsyncHttpResponse.status_codecCr")zTGet headers. :rtype :py:class:`aiohttp.multidict.CIMultiDictProxy` )rrr$r r r rsz AiohttpAsyncHttpResponse.headersc|jIdHS)z"Get response body as text-decoded.N)rtextr$r r r r'zAiohttpAsyncHttpResponse.textcs|jjIdHS)zGet response body as binary.N)rcontentreadr$r r r r)sz AiohttpAsyncHttpResponse.contentcr&)z"Get response body as json-decoded.N)rjsonr$r r r r+r(zAiohttpAsyncHttpResponse.jsoncCs|jj|S)zXGet response body as iterator content (stream). :param int chunk_size: )rr) iter_chunked)r chunk_sizer r r iter_contentsz%AiohttpAsyncHttpResponse.iter_contentN)r,) rrrrrpropertyr%rr'r)r+r/r r r r rts     rN)rlinebotrrrrr r r r s`