grpc.aio._interceptor.StreamStreamCallResponseIterator Class Reference

Inheritance diagram for grpc.aio._interceptor.StreamStreamCallResponseIterator:

Public Member Functions
None	done_writing (self)
ResponseType	read (self)
None	write (self, RequestType request)
Public Member Functions inherited from grpc.aio._interceptor._StreamCallResponseIterator
def	__aiter__ (self)
None	__init__ (self, Union[_base_call.UnaryStreamCall, _base_call.StreamStreamCall] call, AsyncIterable[ResponseType] response_iterator)
None	add_done_callback (self, callback)
bool	cancel (self)
bool	cancelled (self)
grpc.StatusCode	code (self)
Optional[str]	debug_error_string (self)
str	details (self)
bool	done (self)
Optional[Metadata]	initial_metadata (self)
Optional[float]	time_remaining (self)
Optional[Metadata]	trailing_metadata (self)
None	wait_for_connection (self)
Public Member Functions inherited from grpc.aio._base_call.StreamStreamCall
AsyncIterable[ResponseType]	__aiter__ (self)
Public Member Functions inherited from grpc.aio._base_call.Call
grpc.StatusCode	code (self)
str	details (self)
Metadata	initial_metadata (self)
Metadata	trailing_metadata (self)
None	wait_for_connection (self)
Public Member Functions inherited from grpc.aio._base_call.RpcContext
None	add_done_callback (self, DoneCallbackType callback)
bool	cancel (self)
bool	cancelled (self)
bool	done (self)
Optional[float]	time_remaining (self)

Private Member Functions
bool	_done_writing_flag (self)

Detailed Description

StreamStreamCall class wich uses an alternative response iterator.

Definition at line 982 of file aio/_interceptor.py.

Member Function Documentation

_done_writing_flag()

bool grpc.aio._interceptor.StreamStreamCallResponseIterator._done_writing_flag (   self )

private

Definition at line 1003 of file aio/_interceptor.py.

done_writing()

None grpc.aio._interceptor.StreamStreamCallResponseIterator.done_writing

(

self

)

Notifies server that the client is done sending messages.

After done_writing is called, any additional invocation to the write
function will fail. This function is idempotent.

Reimplemented from grpc.aio._base_call.StreamStreamCall.

Definition at line 996 of file aio/_interceptor.py.

read()

ResponseType grpc.aio._interceptor.StreamStreamCallResponseIterator.read

(

self

)

Reads one message from the stream.

Read operations must be serialized when called from multiple
coroutines.

Returns:
  A response message, or an `grpc.aio.EOF` to indicate the end of the
  stream.

Reimplemented from grpc.aio._base_call.StreamStreamCall.

Definition at line 985 of file aio/_interceptor.py.

write()

None grpc.aio._interceptor.StreamStreamCallResponseIterator.write	(		self,
		RequestType	request
	)

Writes one message to the stream.

Raises:
  An RpcError exception if the write failed.

Reimplemented from grpc.aio._base_call.StreamStreamCall.

Definition at line 990 of file aio/_interceptor.py.

---

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

• aio/_interceptor.py