Inheritance diagram for grpc.aio._base_channel.StreamStreamMultiCallable:
Public Member Functions | |
| _base_call.StreamStreamCall | __call__ (self, Optional[RequestIterableType] request_iterator=None, Optional[float] timeout=None, Optional[MetadataType] metadata=None, Optional[grpc.CallCredentials] credentials=None, Optional[bool] wait_for_ready=None, Optional[grpc.Compression] compression=None) |
Detailed Description
Enables asynchronous invocation of a bidirectional-streaming RPC.
Definition at line 145 of file _base_channel.py.
Member Function Documentation
◆ __call__()
| _base_call.StreamStreamCall grpc.aio._base_channel.StreamStreamMultiCallable.__call__ | ( | self, | |
| Optional[RequestIterableType] | request_iterator = None, |
||
| Optional[float] | timeout = None, |
||
| Optional[MetadataType] | metadata = None, |
||
| Optional[grpc.CallCredentials] | credentials = None, |
||
| Optional[bool] | wait_for_ready = None, |
||
| Optional[grpc.Compression] | compression = None |
||
| ) |
Enables asynchronous invocation of a bidirectional-streaming RPC.
Asynchronously invokes the underlying RPC.
Args:
request_iterator: An optional async iterable or iterable of request
messages for the RPC.
timeout: An optional duration of time in seconds to allow
for the RPC.
metadata: Optional :term:`metadata` to be transmitted to the
service-side of the RPC.
credentials: An optional CallCredentials for the RPC. Only valid for
secure Channel.
wait_for_ready: This is an EXPERIMENTAL argument. An optional
flag to enable :term:`wait_for_ready` mechanism.
compression: An element of grpc.compression, e.g.
grpc.compression.Gzip. This is an EXPERIMENTAL option.
Returns:
A StreamStreamCall object.
Raises:
RpcError: Indicates that the RPC terminated with non-OK status. The
raised RpcError will also be a Call for the RPC affording the RPC's
metadata, status code, and details.
Definition at line 149 of file _base_channel.py.
The documentation for this class was generated from the following file: