grpc.aio._call.StreamStreamCall Class Reference

Inheritance diagram for grpc.aio._call.StreamStreamCall:

Public Member Functions
None	__init__ (self, Optional[RequestIterableType] request_iterator, Optional[float] deadline, Metadata metadata, Optional[grpc.CallCredentials] credentials, Optional[bool] wait_for_ready, cygrpc.AioChannel channel, bytes method, SerializingFunction request_serializer, DeserializingFunction response_deserializer, asyncio.AbstractEventLoop loop)
Public Member Functions inherited from grpc.aio._call._StreamRequestMixin
bool	cancel (self)
None	done_writing (self)
None	wait_for_connection (self)
None	write (self, RequestType request)
Public Member Functions inherited from grpc.aio._call.Call
None	__del__ (self)
None	__init__ (self, cygrpc._AioCall cython_call, Metadata metadata, SerializingFunction request_serializer, DeserializingFunction response_deserializer, asyncio.AbstractEventLoop loop)
str	__repr__ (self)
str	__str__ (self)
None	add_done_callback (self, DoneCallbackType callback)
bool	cancelled (self)
grpc.StatusCode	code (self)
str	debug_error_string (self)
str	details (self)
bool	done (self)
Metadata	initial_metadata (self)
Optional[float]	time_remaining (self)
Metadata	trailing_metadata (self)
Public Member Functions inherited from grpc.aio._call._StreamResponseMixin
AsyncIterable[ResponseType]	__aiter__ (self)
bool	cancel (self)
ResponseType	read (self)
Public Member Functions inherited from grpc.aio._base_call.StreamStreamCall
AsyncIterable[ResponseType]	__aiter__ (self)
None	done_writing (self)
Union[EOFType, ResponseType]	read (self)
None	write (self, RequestType request)
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
def	_prepare_rpc (self)

Private Attributes
	_initializer

Detailed Description

Object for managing stream-stream RPC calls.

Returned when an instance of `StreamStreamMultiCallable` object is called.

Definition at line 614 of file _call.py.

Constructor & Destructor Documentation

__init__()

None grpc.aio._call.StreamStreamCall.__init__	(		self,
		Optional[RequestIterableType]	request_iterator,
		Optional[float]	deadline,
		Metadata	metadata,
		Optional[grpc.CallCredentials]	credentials,
		Optional[bool]	wait_for_ready,
		cygrpc.AioChannel	channel,
		bytes	method,
		SerializingFunction	request_serializer,
		DeserializingFunction	response_deserializer,
		asyncio.AbstractEventLoop	loop
	)

Definition at line 622 of file _call.py.

Member Function Documentation

_prepare_rpc()

def grpc.aio._call.StreamStreamCall._prepare_rpc (   self )

private

This method prepares the RPC for receiving/sending messages.

All other operations around the stream should only happen after the
completion of this method.

Definition at line 636 of file _call.py.

Member Data Documentation

_initializer

grpc.aio._call.StreamStreamCall._initializer

private

Definition at line 626 of file _call.py.

---

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

• _call.py