a v=ic@sdZddlZddlZddlZddlZddlZddlmZe Z Gddde Z Gddde ZeeZdd ZGd d d eZd d ZddZddZdZejdkrddlmZddlmZddlmZddlmZeeeeefZdS)zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. N)cygrpcc@seZdZdZdZdS)ChannelOptionszIndicates a channel option unique to gRPC Python. This enumeration is part of an EXPERIMENTAL API. Attributes: SingleThreadedUnaryStream: Perform unary-stream RPCs on a single thread. SingleThreadedUnaryStreamN)__name__ __module__ __qualname____doc__rr r k/home/droni/.local/share/virtualenvs/DPS-5Je3_V2c/lib/python3.9/site-packages/grpc/experimental/__init__.pyrsrc@seZdZdZdS) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nrrrrr r r r r )sr cCstS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )_insecure_channel_credentialsr r r r insecure_channel_credentials3src@seZdZdZdS)ExperimentalApiWarningz&A warning that an API is experimental.Nr r r r r r;srcCs8|tvr4t|d|d}tj|td|ddS)Nz8'{}' is an experimental API. It is subject to change or z5removal between minor releases. Proceed with caution.) stacklevel)_EXPERIMENTAL_APIS_USEDaddformatwarningswarnr)Zapi_nameZ stack_offsetmsgr r r _warn_experimental?s rcstfdd}|S)Ncstjd|i|S)N)rr)argskwargsfr r _wrapperJs z"experimental_api.._wrapper) functoolswraps)rrr rr experimental_apiHsr!cCsh|sdS|js:|js&|j||jdS|j||jdSn*|jsR|j||jdS|j||jdSdS)aWraps the server method handler function. The server implementation requires all server handlers being wrapped as RpcMethodHandler objects. This helper function ease the pain of writing server handler wrappers. Args: wrapper: A wrapper function that takes in a method handler behavior (the actual function) and returns a wrapped function. handler: A RpcMethodHandler object to be wrapped. Returns: A newly created RpcMethodHandler. N unary_unary unary_stream stream_unary stream_stream)Zrequest_streamingZresponse_streaming_replacer#r%r'r))wrapperhandlerr r r wrap_server_method_handlerRsr-)rrr rr-)r(r&r$r")rcopyrsysrZgrpcZ grpc._cythonrZ_cygrpcsetrobjectr Exceptionr ZChannelCredentialsZchannel_credentials_insecurer rWarningrrr!r-__all__ version_infoZgrpc._simple_stubsr)r'r%r#r r r r s0    !