o }Mfa@s"dZddlZGdddejZdS)z3Interfaces related to streams of values or objects.Nc@s:eZdZdZejddZejddZejddZdS) Consumerz?Interface for consumers of finite streams of values or objects.cCt)z^Accepts a value. Args: value: Any value accepted by this Consumer. NotImplementedErrorselfvaluer b/var/www/html/analyze/labelStudio/lib/python3.10/site-packages/grpc/framework/foundation/stream.pyconsumezConsumer.consumecCr)z@Indicates to this Consumer that no more values will be supplied.r)rr r r terminateszConsumer.terminatecCr)zSupplies a value and signals that no more values will be supplied. Args: value: Any value accepted by this Consumer. rrr r r consume_and_terminate$r zConsumer.consume_and_terminateN) __name__ __module__ __qualname____doc__abcabstractmethodr r rr r r r rs  r)rrABCrr r r r s