Inheritance diagram for grpc.aio._interceptor.InterceptedStreamUnaryCall:
Public Member Functions | |
| None | __init__ (self, Sequence[StreamUnaryClientInterceptor] interceptors, Optional[RequestIterableType] request_iterator, 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._InterceptedStreamRequestMixin | |
| None | done_writing (self) |
| None | write (self, RequestType request) |
| 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.StreamUnaryCall | |
| Awaitable[ResponseType] | __await__ (self) |
| None | done_writing (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) |
Private Member Functions | |
| StreamUnaryCall | _invoke (self, Sequence[StreamUnaryClientInterceptor] interceptors, bytes method, Optional[float] timeout, Optional[Metadata] metadata, Optional[grpc.CallCredentials] credentials, Optional[bool] wait_for_ready, RequestIterableType request_iterator, SerializingFunction request_serializer, DeserializingFunction response_deserializer) |
Private Attributes | |
| _channel | |
| _loop | |
Detailed Description
Used for running a `StreamUnaryCall` 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 720 of file aio/_interceptor.py.
Constructor & Destructor Documentation
◆ __init__()
| None grpc.aio._interceptor.InterceptedStreamUnaryCall.__init__ | ( | self, | |
| Sequence[StreamUnaryClientInterceptor] | interceptors, | ||
| Optional[RequestIterableType] | request_iterator, | ||
| 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 731 of file aio/_interceptor.py.
Member Function Documentation
◆ _invoke()
|
private |
Run the RPC call wrapped in interceptors
Definition at line 749 of file aio/_interceptor.py.
◆ time_remaining()
| Optional[float] grpc.aio._interceptor.InterceptedStreamUnaryCall.time_remaining | ( | self | ) |
Reimplemented from grpc.aio._interceptor.InterceptedCall.
Definition at line 788 of file aio/_interceptor.py.
Member Data Documentation
◆ _channel
|
private |
Definition at line 733 of file aio/_interceptor.py.
◆ _loop
|
private |
Definition at line 732 of file aio/_interceptor.py.
The documentation for this class was generated from the following file: