grpc.aio._interceptor.InterceptedUnaryUnaryCall Class Reference

Inheritance diagram for grpc.aio._interceptor.InterceptedUnaryUnaryCall:

Public Member Functions
None	__init__ (self, Sequence[UnaryUnaryClientInterceptor] interceptors, RequestType request, Optional[float] timeout, 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)
Optional[float]	time_remaining (self)
Public Member Functions inherited from grpc.aio._interceptor._InterceptedUnaryResponseMixin
def	__await__ (self)
Public Member Functions inherited from grpc.aio._interceptor.InterceptedCall
def	__del__ (self)
None	__init__ (self, asyncio.Task interceptors_task)
None	add_done_callback (self, DoneCallbackType 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[Metadata]	trailing_metadata (self)
None	wait_for_connection (self)
Public Member Functions inherited from grpc.aio._base_call.UnaryUnaryCall
Awaitable[ResponseType]	__await__ (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)

Private Member Functions
UnaryUnaryCall	_invoke (self, Sequence[UnaryUnaryClientInterceptor] interceptors, bytes method, Optional[float] timeout, Optional[Metadata] metadata, Optional[grpc.CallCredentials] credentials, Optional[bool] wait_for_ready, RequestType request, SerializingFunction request_serializer, DeserializingFunction response_deserializer)

Private Attributes
	_channel
	_loop

Detailed Description

Used for running a `UnaryUnaryCall` wrapped by interceptors.

For the `__await__` method is it is proxied to the intercepted call only when
the interceptor task is finished.

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

Constructor & Destructor Documentation

__init__()

None grpc.aio._interceptor.InterceptedUnaryUnaryCall.__init__	(		self,
		Sequence[UnaryUnaryClientInterceptor]	interceptors,
		RequestType	request,
		Optional[float]	timeout,
		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 575 of file aio/_interceptor.py.

Member Function Documentation

_invoke()

UnaryUnaryCall grpc.aio._interceptor.InterceptedUnaryUnaryCall._invoke (   self, Sequence[UnaryUnaryClientInterceptor]  interceptors, bytes  method, Optional[float]  timeout, Optional[Metadata]  metadata, Optional[grpc.CallCredentials]  credentials, Optional[bool]  wait_for_ready, RequestType  request, SerializingFunction  request_serializer, DeserializingFunction  response_deserializer  )

private

Run the RPC call wrapped in interceptors

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

time_remaining()

Optional[float] grpc.aio._interceptor.InterceptedUnaryUnaryCall.time_remaining

(

self

)

Reimplemented from grpc.aio._interceptor.InterceptedCall.

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

Member Data Documentation

_channel

grpc.aio._interceptor.InterceptedUnaryUnaryCall._channel

private

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

_loop

grpc.aio._interceptor.InterceptedUnaryUnaryCall._loop

private

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

---

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

• aio/_interceptor.py