ph SSKrSSKJrJr SSKJr SSKJrJrJ r J r SSK J r J r SrSr1Skr"S S \5r"S S \5rg) N)ABCabstractmethod)ThreadPoolExecutor)AnyMappingOptionalUnion) HttpClient HttpResponsez)HttpClient/1.0 (+https://example.invalid)g>@>cl\rSrSr\SS\S\\\\S\\ \ \ \ \ 44S\\\\4S\\ S\ S\\\44 S jj5r\SS\S\\\\S\\ \ \ \ \ 44S\\\\4S\\ S\ S\\\44 S jj5r\SS\S \\S \\\\4S\\\\S\\ \ \ \ \ 44S\\\\4S\\ S\ S\\\44S jj5r\SS\S \\S \\\\4S\\\\S\\ \ \ \ \ 44S\\\\4S\\ S\ S\\\44Sjj5r\SS\S \\S \\\\4S\\\\S\\ \ \ \ \ 44S\\\\4S\\ S\ S\\\44Sjj5r\SS\S\S\\\\S\\ \ \ \ \ 44S\\\\4S\\\\4S\\ S\4Sjj5rSrg)AsyncHTTPClient Npathparamsheaderstimeout expect_jsonreturnc # g7f)z Invoke HTTP GET request.Nselfrrrrrs X/home/james-whalen/.local/lib/python3.13/site-packages/redis/asyncio/http/http_client.pygetAsyncHTTPClient.get  c # g7f)z Invoke HTTP DELETE request.Nrrs rdeleteAsyncHTTPClient.deleter!r" json_bodydatac # g7f)z Invoke HTTP POST request.Nrrrr&r'rrrrs rpostAsyncHTTPClient.post,  r"c # g7f)z Invoke HTTP PUT request.Nrr)s rputAsyncHTTPClient.put=r,r"c # g7f)z Invoke HTTP PATCH request.Nrr)s rpatchAsyncHTTPClient.patchNr,r"methodbodyc # g7f)z' Invoke HTTP request with given method.Nr)rr3rrrr4rs rrequestAsyncHTTPClient.request_s  r"rNNNTNNNNNTNNNN)__name__ __module__ __qualname____firstlineno__rstrrrr intfloatboollisttupler rrr$bytesr*r.r1r6__static_attributes__rrrr sL /3#'      CtS#udD%GHH I   '#s(+,  %     |S !     /3#'      CtS#udD%GHH I   '#s(+,  %     |S !    $(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S !  $(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S !  $(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S !   /3,0#'       CtS#udD%GHH I  '#s(+,  uUCZ()  %       rGrcN\rSrSrSrSS\S\SS4SjjrSS\S \ \ \\ S\\\ \ \\44S \ \ \\4S \ \ S \ S\ \\44 S jjrSS\S \ \ \\ S\\\ \ \\44S \ \ \\4S \ \ S \ S\ \\44 SjjrSS\S\ \S\ \ \\4S \ \ \\ S\\\ \ \\44S \ \ \\4S \ \ S \ S\ \\44SjjrSS\S\ \S\ \ \\4S \ \ \\ S\\\ \ \\44S \ \ \\4S \ \ S \ S\ \\44SjjrSS\S\ \S\ \ \\4S \ \ \\ S\\\ \ \\44S \ \ \\4S \ \ S \ S\ \\44SjjrSS\S\S \ \ \\ S\\\ \ \\44S \ \ \\4S\ \ \\4S \ \ S\4SjjrSrg)AsyncHTTPClientWrapperpzF An async wrapper around sync HTTP client with thread pool execution. client max_workersrNc,Xl[US9Ulg)a Initialize a new HTTP client instance. Args: client: Sync HTTP client instance. max_workers: Maximum number of concurrent requests. The client supports both regular HTTPS with server verification and mutual TLS authentication. For server verification, provide CA certificate information via ca_file, ca_path or ca_data. For mutual TLS, additionally provide a client certificate and key via client_cert_file and client_key_file. )rLN)rKr _executor)rrKrLs r__init__AsyncHTTPClientWrapper.__init__us + DrGrrrrrc # [R"5nURURURR XX4U5IShvN $N7fN)asyncioget_event_looprun_in_executorrNrKrrrrrrrloops rrAsyncHTTPClientWrapper.getsI%%')) NNDKKOOT7[    sA AAAc # [R"5nURURURR UUUUU5IShvN $N7frR)rSrTrUrNrKr$rVs rr$AsyncHTTPClientWrapper.deletesU%%')) NN KK           sAAAAr&r'c # [R"5nURURURR UUUUUUU5 IShvN $N7frR)rSrTrUrNrKr* rrr&r'rrrrrWs rr*AsyncHTTPClientWrapper.posts[%%')) NN KK             AAAAc # [R"5nURURURR UUUUUUU5 IShvN $N7frR)rSrTrUrNrKr.r\s rr.AsyncHTTPClientWrapper.putsY%%')) NN KKOO           r^c # [R"5nURURURR UUUUUUU5 IShvN $N7frR)rSrTrUrNrKr1r\s rr1AsyncHTTPClientWrapper.patchs[%%')) NN KK             r^r3r4c # [R"5nURURURR UUUUUU5IShvN $N7frR)rSrTrUrNrKr6)rr3rrrr4rrWs rr6AsyncHTTPClientWrapper.requestsX%%')) NN KK            sAAAA)rNrK) r8r9r:)r;r<r=r>__doc__r r@rOr?rrr rArBrCrDr rrr$rEr*r.r1r6rFrrGrrIrIpsEzEETE* /3#'      CtS#udD%GHH I   '#s(+,  %     |S !  ( /3#'    CtS#udD%GHH I  '#s(+,  %   |S ! 0$(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S ! 8$(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S ! 8$(,0 /3#'   C= uUCZ()   CtS#udD%GHH I  '#s(+, %   |S ! > /3,0#'    CtS#udD%GHH I  '#s(+, uUCZ() %    rGrI)rSabcrrconcurrent.futuresrtypingrrrr redis.http.http_clientr r DEFAULT_USER_AGENTDEFAULT_TIMEOUTRETRY_STATUS_CODESrrIrrGrrnsE#100;@.` c` FY _Y rG