grpc.aio._call.UnaryStreamCall Class Reference

Inheritance diagram for grpc.aio._call.UnaryStreamCall:

Public Member Functions
None	__init__ (self, RequestType request, 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)
None	wait_for_connection (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._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._base_call.UnaryStreamCall
AsyncIterable[ResponseType]	__aiter__ (self)
Union[EOFType, ResponseType]	read (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)
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
ResponseType	_send_unary_request (self)

Private Attributes
	_request
	_send_unary_request_task

Detailed Description

Object for managing unary-stream RPC calls.

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

Definition at line 535 of file _call.py.

Constructor & Destructor Documentation

__init__()

None grpc.aio._call.UnaryStreamCall.__init__	(		self,
		RequestType	request,
		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 544 of file _call.py.

Member Function Documentation

_send_unary_request()

ResponseType grpc.aio._call.UnaryStreamCall._send_unary_request (   self )

private

Definition at line 559 of file _call.py.

wait_for_connection()

None grpc.aio._call.UnaryStreamCall.wait_for_connection

(

self

)

Waits until connected to peer and raises aio.AioRpcError if failed.

This is an EXPERIMENTAL method.

This method ensures the RPC has been successfully connected. Otherwise,
an AioRpcError will be raised to explain the reason of the connection
failure.

This method is recommended for building retry mechanisms.

Reimplemented from grpc.aio._base_call.Call.

Definition at line 570 of file _call.py.

Member Data Documentation

_request

grpc.aio._call.UnaryStreamCall._request

private

Definition at line 548 of file _call.py.

_send_unary_request_task

grpc.aio._call.UnaryStreamCall._send_unary_request_task

private

Definition at line 549 of file _call.py.

---

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

• _call.py