
    (pha                     :    S r SSKr " S S\R                  5      rg)z3Interfaces related to streams of values or objects.    Nc                       \ rS rSrSr\R                  S 5       r\R                  S 5       r\R                  S 5       r	Sr
g)Consumer   z?Interface for consumers of finite streams of values or objects.c                     [        5       e)zFAccepts a value.

Args:
  value: Any value accepted by this Consumer.
NotImplementedErrorselfvalues     S/var/www/html/venv/lib/python3.13/site-packages/grpc/framework/foundation/stream.pyconsumeConsumer.consume        "##    c                     [        5       e)z@Indicates to this Consumer that no more values will be supplied.r   )r
   s    r   	terminateConsumer.terminate   s     "##r   c                     [        5       e)zxSupplies 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_terminateConsumer.consume_and_terminate$   r   r    N)__name__
__module____qualname____firstlineno____doc__abcabstractmethodr   r   r   __static_attributes__r   r   r   r   r      sQ    I$ $ 	$ $ 	$ $r   r   )r   r   ABCr   r   r   r   <module>r!      s    : 
$sww $r   