AgLdZddlZddlZddlZddlZddlZddlmZe Z Gdde Z Gdde Zejej ZdZGd d eZd Zd Zd ZdZej2dkDr"ddlmZddlmZddlmZddlmZeeeeefzZyy)zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. N)cygrpcceZdZdZdZy)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__rO/var/www/openai/venv/lib/python3.12/site-packages/grpc/experimental/__init__.pyrrs!<r rceZdZdZy) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nrrr r r r r rr*sNr rctS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )_insecure_channel_credentialsr r r insecure_channel_credentialsr5s )(r ceZdZdZy)ExperimentalApiWarningz&A warning that an API is experimental.Nrr r r rr=s0r rc|tvrItj|dj|dz}tj|t d|zyy)Nz8'{}' is an experimental API. It is subject to change or z5removal between minor releases. Proceed with caution.) stacklevel)_EXPERIMENTAL_APIS_USEDaddformatwarningswarnr)api_name stack_offsetmsgs r _warn_experimentalr!AsX..##H- F M M F F  c1a,>NO/r cBtjfd}|S)Nc@tjd|i|S)N)r!r)argskwargsfs r _wrapperz"experimental_api.._wrapperNs!1::q)$!&!!r ) functoolswraps)r'r(s` r experimental_apir+Ms%__Q"" Or c`|sy|jsP|js"|j||jS|j||jS|js"|j||j S|j||j S)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)request_streamingresponse_streaming_replacer.r0r2r4)wrapperhandlers r wrap_server_method_handlerr:Vs   $ $))##8K8K0L#M M##9M9M1N#O O))##9M9M1N#O O##%g&;&;<$ r )rrrrr:)r3r1r/r-)r copyr)sysrgrpc grpc._cythonr_cygrpcsetrobjectr ExceptionrChannelCredentialschannel_credentials_insecurerrWarningrr!r+r:__all__ version_infogrpc._simple_stubsr4r2r0r.r r r rKs    *%