Ng9 dZddlZddlmZGddejejddZGddejejdd Zeejj j ddddZ d Z d Z dS) z;Utilities for use with the base interface of RPC Framework.N)baseceZdZdZdS) _Completionz,A trivial implementation of base.Completion.N__name__ __module__ __qualname____doc__d/var/www/html/ai-engine/env/lib/python3.11/site-packages/grpc/framework/interfaces/base/utilities.pyrrs7666r rterminal_metadatacodemessageceZdZdZdS) _Subscriptionz.A trivial implementation of base.Subscription.Nrr r r rr#s9888r r)kindtermination_callback allowanceoperatorprotocol_receiverc$t|||S)a?Creates 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. )rrs r completionr8s ($ 8 88r cPttjjjdd||S)ahCreates 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 SubscriptionKindFULL)rrs r full_subscriptionrFs+  #T4;L  r )r collectionsgrpc.framework.interfaces.baser Completion namedtuplerrrrNONE_NONE_SUBSCRIPTIONrrr r r r&s BA////// 7 7 7 7 7OK  7 7 7 9 9 9 9 9K    9 9 9 #]tT4 9 9 9     r