a ù!f— ã@szdZddlZddlmZGdd„deje dd¡ƒZGdd„deje dd ¡ƒZeejj j ddddƒZ d d „Z d d „Z dS)z;Utilities for use with the base interface of RPC Framework.éN)Úbasec@seZdZdZdS)Ú _Completionz,A trivial implementation of base.Completion.N©Ú__name__Ú __module__Ú __qualname__Ú__doc__©r r úi/var/www/html/python-backend/venv/lib/python3.9/site-packages/grpc/framework/interfaces/base/utilities.pyrsr©Zterminal_metadataÚcodeÚmessagec@seZdZdZdS)Ú _Subscriptionz.A trivial implementation of base.Subscription.Nrr r r r rsr)ÚkindZtermination_callbackÚ allowanceÚoperatorÚprotocol_receivercCs t|||ƒS)a1Creates a base.Completion aggregating the given operation values. Args: terminal_metadata: A terminal metadata value for an operaton. code: A code value for an operation. message: A message value for an operation. Returns: A base.Completion aggregating the given operation values. )rr r r r Ú completion-s rcCsttjjjdd||ƒS)aZCreates a "full" base.Subscription for the given base.Operator. Args: operator: A base.Operator to be used in an operation. protocol_receiver: A base.ProtocolReceiver to be used in an operation. Returns: A base.Subscription of kind base.Subscription.Kind.FULL wrapping the given base.Operator and base.ProtocolReceiver. N)rrÚ SubscriptionÚKindZFULL)rrr r r Úfull_subscription;s ÿr)rÚ collectionsZgrpc.framework.interfaces.baserZ CompletionÚ namedtuplerrrrÚNONEZ_NONE_SUBSCRIPTIONrrr r r r Ús  ÿ  ÿ ÿ