ci5 rdZddlZddlmZmZmZmZmZmZm Z m Z ddl Z GddeZ Gdde e jZ Gdd e je jZGd d e j"e j$e j&e j(ej* Zd eeegefdeeegeffdZy)z(Base class for client-side interceptors.N)AnyCallableIterator NamedTupleOptionalSequenceTupleUnionceZdZUeed<eeed<eeeee ee ffed<ee jed<ee ed<eed<y)_ClientCallDetailsFieldsmethodtimeoutmetadata credentialswait_for_ready compressionN)__name__ __module__ __qualname__str__annotations__rfloatrr r bytesgrpcCallCredentialsboolr>/tmp/pip-target-z3e9_cxr/lib/python/grpc_interceptor/client.pyr r sU K e_xc5e+<&< =>??$..//TN"rr ceZdZdZy)ClientCallDetailszqDescribes an RPC to be invoked. See https://grpc.github.io/grpc/python/grpc.html#grpc.ClientCallDetails Nrrr__doc__rrrr!r!s   rr!ceZdZdZy)ClientInterceptorReturnTypez7Return type for the ClientInterceptor.intercept method.Nr"rrrr%r%sArr%c eZdZdZej dededejde fdZ dedejdefd Z dedejdefd Z dedejd eefd Zdedejd eefd Zy)ClientInterceptorzBase class for client-side interceptors. To implement an interceptor, subclass this class and override the intercept method. r request_or_iterator call_detailsreturnc|||S)a[Override this method to implement a custom interceptor. This method is called for all unary and streaming RPCs. The interceptor implementation should call `method` using a `grpc.ClientCallDetails` and the `request_or_iterator` object as parameters. The `request_or_iterator` parameter may be type checked to determine if this is a singluar request for unary RPCs or an iterator for client-streaming or client-server streaming RPCs. Args: method: A function that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying channel. request_or_iterator: RPC request message or iterator of request messages for streaming requests. call_details: Describes an RPC to be invoked. Returns: The type of the return should match the type of the return value received by calling `method`. This is an object that is both a `Call `_ for the RPC and a `Future `_. The actual result from the RPC can be got by calling `.result()` on the value returned from `method`. r)selfr r(r)s r interceptzClientInterceptor.intercept-sD)<88r continuationrequestc:|jt|||S)zImplementation of grpc.UnaryUnaryClientInterceptor. This is not part of the grpc_interceptor.ClientInterceptor API, but must have a public name. Do not override it, unless you know what you're doing. r- _swap_argsr,r.r)r/s rintercept_unary_unaryz'ClientInterceptor.intercept_unary_unaryQ~~j6NNrc:|jt|||S)zImplementation of grpc.UnaryStreamClientInterceptor. This is not part of the grpc_interceptor.ClientInterceptor API, but must have a public name. Do not override it, unless you know what you're doing. r1r3s rintercept_unary_streamz(ClientInterceptor.intercept_unary_stream^r5rrequest_iteratorc:|jt|||S)zImplementation of grpc.StreamUnaryClientInterceptor. This is not part of the grpc_interceptor.ClientInterceptor API, but must have a public name. Do not override it, unless you know what you're doing. r1r,r.r)r8s rintercept_stream_unaryz(ClientInterceptor.intercept_stream_unaryk~~j68H,WWrc:|jt|||S)zImplementation of grpc.StreamStreamClientInterceptor. This is not part of the grpc_interceptor.ClientInterceptor API, but must have a public name. Do not override it, unless you know what you're doing. r1r:s rintercept_stream_streamz)ClientInterceptor.intercept_stream_streamxr<rN)rrrr#abcabstractmethodrrrr!r%r-r4r7rr;r>rrrr'r'!s  !9!9!!9,, !9 % !9!9F O O,, O O O O,, O O X X,, X#3- X X X,, X#3- Xrr') metaclassfnr*cfd}|S)Nc||S)Nr)xyrBs rnew_fnz_swap_args..new_fns!Qxrr)rBrGs` rr2r2s Mr)r#r?typingrrrrrrr r rr r!CallFuturer%UnaryUnaryClientInterceptorUnaryStreamClientInterceptorStreamUnaryClientInterceptorStreamStreamClientInterceptorABCMetar'r2rrrrPs. XXX z 0$2H2H  $))T[[ bX$$%%%%&&kk bXJ8S#JO,3*c/1Jr