U "FZha@s"dZddlZGdddejZdS)z3Interfaces related to streams of values or objects.Nc@s:eZdZdZejddZejddZejddZdS) Consumerz?Interface for consumers of finite streams of values or objects.cCs tdS)z^Accepts a value. Args: value: Any value accepted by this Consumer. NNotImplementedErrorselfvaluerg/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/grpc/framework/foundation/stream.pyconsumeszConsumer.consumecCs tdS)z@Indicates to this Consumer that no more values will be supplied.Nr)rrrr terminateszConsumer.terminatecCs tdS)zSupplies a value and signals that no more values will be supplied. Args: value: Any value accepted by this Consumer. Nrrrrr consume_and_terminate$szConsumer.consume_and_terminateN) __name__ __module__ __qualname____doc__abcabstractmethodr r r rrrr rs  r)rrABCrrrrr s