ruạṛ
a K��f � @ s� d Z ddlZddlZddlZddlZddlZddlmZ e � Z G dd� de�ZG dd� de �Ze�e�� �Zdd � ZG d d� de�Zdd � Zdd� Zdd� ZdZejdkr�ddlmZ ddlmZ ddlmZ ddlmZ eeeeef ZdS )zbgRPC's experimental APIs. These APIs are subject to be removed during any minor version release. � N)�cygrpcc @ s e Zd ZdZdZdS )�ChannelOptionsz�Indicates 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__r � r r �~/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/experimental/__init__.pyr s r c @ s e Zd ZdZdS )� UsageErrorzDRaised by the gRPC library to indicate usage not allowed by the API.N�r r r r r r r r r * s r c C s t S )zeCreates a ChannelCredentials for use with an insecure channel. THIS IS AN EXPERIMENTAL API. )�_insecure_channel_credentialsr r r r �insecure_channel_credentials5 s r c @ s e Zd ZdZdS )�ExperimentalApiWarningz&A warning that an API is experimental.Nr r r r r r = s r c C s8 | t vr4t �| � d�| �d }tj|td| d� d S )Nz8'{}' is an experimental API. It is subject to change or z5removal between minor releases. Proceed with caution.� )� stacklevel)�_EXPERIMENTAL_APIS_USED�add�format�warnings�warnr )�api_name�stack_offset�msgr r r �_warn_experimentalA s ���r c s t �� �� fdd��}|S )Nc s t � jd� � | i |��S )N� )r r )�args�kwargs��fr r �_wrapperN s z"experimental_api.<locals>._wrapper)� functools�wraps)r r r r r �experimental_apiM s r# c C sh |sdS |j s:|js&|j| |j�d�S |j| |j�d�S n*|jsR|j| |j�d�S |j| |j�d�S dS )a� Wraps 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_streaming�response_streaming�_replacer% r'