Inheritance diagram for grpc.aio._interceptor.InterceptedStreamStreamCall:
Public Member Functions | |
| None | __init__ (self, Sequence[StreamStreamClientInterceptor] 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._InterceptedStreamResponseMixin | |
| AsyncIterable[ResponseType] | __aiter__ (self) |
| ResponseType | read (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.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) |
Private Member Functions | |
| StreamStreamCall | _invoke (self, Sequence[StreamStreamClientInterceptor] 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 | |
Static Private Attributes | |
| _last_returned_call_from_interceptors = Optional[_base_call.UnaryStreamCall] | |
Detailed Description
Used for running a `StreamStreamCall` wrapped by interceptors.
Definition at line 794 of file aio/_interceptor.py.
Constructor & Destructor Documentation
◆ __init__()
| None grpc.aio._interceptor.InterceptedStreamStreamCall.__init__ | ( | self, | |
| Sequence[StreamStreamClientInterceptor] | 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 802 of file aio/_interceptor.py.
Member Function Documentation
◆ _invoke()
|
private |
Run the RPC call wrapped in interceptors
Definition at line 822 of file aio/_interceptor.py.
◆ time_remaining()
| Optional[float] grpc.aio._interceptor.InterceptedStreamStreamCall.time_remaining | ( | self | ) |
Reimplemented from grpc.aio._interceptor.InterceptedCall.
Definition at line 871 of file aio/_interceptor.py.
Member Data Documentation
◆ _channel
|
private |
Definition at line 804 of file aio/_interceptor.py.
◆ _last_returned_call_from_interceptors
|
staticprivate |
Definition at line 799 of file aio/_interceptor.py.
◆ _loop
|
private |
Definition at line 803 of file aio/_interceptor.py.
The documentation for this class was generated from the following file: