ghXdZddlZddlZddlZddlZddlZddlmZe Z Gdde Z Gdde ZejejZdZGd d eZd Zd Zd ZdZejdkr#ddlmZddlmZddlmZddlmZeeeeefzZdSdS)zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. N)cygrpcceZdZdZdZdS)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__rb/var/www/html/services/rag-service/venv/lib/python3.11/site-packages/grpc/experimental/__init__.pyrrs"!<r rceZdZdZdS) UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.Nrrr r r r r rr*sNNNNr rctS)zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )_insecure_channel_credentialsr r r insecure_channel_credentialsr5s )(r ceZdZdZdS)ExperimentalApiWarningz&A warning that an API is experimental.Nrr r r rr=s0000r rc|tvrSt|d|dz}tj|t d|zdSdS)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!Asv...##H--- F M M  F F  c1a,>NOOOOOO/.r cFtjfd}|S)Nc>tjd|i|S)N)r!r)argskwargsfs r _wrapperz"experimental_api.._wrapperNs*1:q)))q$!&!!!r ) functoolswraps)r'r(s` r experimental_apir+Ms8_Q""""" Or cT|sdS|jsO|js$|||jS|||jS|js$|||jS|||jS)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 t  $ ) P##8K0L0L#MM M##9M1N1N#OO O) ##9M1N1N#OO O##%gg&;<<$ r )rrrrr:)r3r1r/r-)r copyr)sysrgrpc grpc._cythonr_cygrpcsetrobjectr ExceptionrChannelCredentialschannel_credentials_insecurerrWarningrr!r+r:__all__ version_infogrpc._simple_stubsr4r2r0r.r r r rKs    ******#%% < < < <