
    Nga                     8    d Z ddlZ G d dej                  ZdS )z3Interfaces related to streams of values or objects.    Nc                   r    e Zd ZdZej        d             Zej        d             Zej        d             ZdS )Consumerz?Interface for consumers of finite streams of values or objects.c                     t                      )z^Accepts a value.

        Args:
          value: Any value accepted by this Consumer.
        NotImplementedErrorselfvalues     \/var/www/html/ai-engine/env/lib/python3.11/site-packages/grpc/framework/foundation/stream.pyconsumezConsumer.consume        "###    c                     t                      )z@Indicates to this Consumer that no more values will be supplied.r   )r	   s    r   	terminatezConsumer.terminate   s     "###r   c                     t                      )zSupplies a value and signals that no more values will be supplied.

        Args:
          value: Any value accepted by this Consumer.
        r   r   s     r   consume_and_terminatezConsumer.consume_and_terminate$   r   r   N)	__name__
__module____qualname____doc__abcabstractmethodr   r   r    r   r   r   r      su        II$ $ $ 	$ $ $ 	$ $ $ $ $r   r   )r   r   ABCr   r   r   r   <module>r      sL    : 9 



$ $ $ $ $sw $ $ $ $ $r   