a
    v=icm  ã                   @   s0   d Z ddlZddlZG dd„ de ej¡ƒZdS )z3Interfaces related to streams of values or objects.é    Nc                   @   s:   e Zd ZdZejdd„ ƒZejdd„ ƒZejdd„ ƒZdS )	ÚConsumerz?Interface for consumers of finite streams of values or objects.c                 C   s
   t ƒ ‚dS )zRAccepts a value.

    Args:
      value: Any value accepted by this Consumer.
    N©ÚNotImplementedError©ÚselfÚvalue© r   úq/home/droni/.local/share/virtualenvs/DPS-5Je3_V2c/lib/python3.9/site-packages/grpc/framework/foundation/stream.pyÚconsume   s    zConsumer.consumec                 C   s
   t ƒ ‚dS )z@Indicates to this Consumer that no more values will be supplied.Nr   )r   r   r   r	   Ú	terminate!   s    zConsumer.terminatec                 C   s
   t ƒ ‚dS )z„Supplies a value and signals that no more values will be supplied.

    Args:
      value: Any value accepted by this Consumer.
    Nr   r   r   r   r	   Úconsume_and_terminate&   s    zConsumer.consume_and_terminateN)	Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚabcÚabstractmethodr
   r   r   r   r   r   r	   r      s   

r   )r   r   ÚsixÚwith_metaclassÚABCMetar   r   r   r   r	   Ú<module>   s   