grpc.framework.foundation.stream.Consumer Class Reference

Inheritance diagram for grpc.framework.foundation.stream.Consumer:

Public Member Functions
def	consume (self, value)
def	consume_and_terminate (self, value)
def	terminate (self)

Detailed Description

Interface for consumers of finite streams of values or objects.

Definition at line 21 of file stream.py.

Member Function Documentation

consume()

def grpc.framework.foundation.stream.Consumer.consume	(		self,
			value
	)

Accepts a value.

    Args:
      value: Any value accepted by this Consumer.

Reimplemented in grpc.framework.foundation.stream_util.ThreadSwitchingConsumer, grpc.framework.foundation.stream_util.IterableConsumer, and grpc.framework.foundation.stream_util.TransformingConsumer.

Definition at line 25 of file stream.py.

consume_and_terminate()

def grpc.framework.foundation.stream.Consumer.consume_and_terminate	(		self,
			value
	)

Supplies a value and signals that no more values will be supplied.

    Args:
      value: Any value accepted by this Consumer.

Reimplemented in grpc.framework.foundation.stream_util.ThreadSwitchingConsumer, grpc.framework.foundation.stream_util.IterableConsumer, and grpc.framework.foundation.stream_util.TransformingConsumer.

Definition at line 39 of file stream.py.

terminate()

def grpc.framework.foundation.stream.Consumer.terminate

(

self

)

Indicates to this Consumer that no more values will be supplied.

Reimplemented in grpc.framework.foundation.stream_util.ThreadSwitchingConsumer, grpc.framework.foundation.stream_util.IterableConsumer, and grpc.framework.foundation.stream_util.TransformingConsumer.

Definition at line 34 of file stream.py.

---

The documentation for this class was generated from the following file:

• stream.py