Inheritance diagram for grpc.aio._base_channel.UnaryStreamMultiCallable:
Public Member Functions | |
| _base_call.UnaryStreamCall | __call__ (self, Any request, *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 server-streaming RPC.
Definition at line 67 of file _base_channel.py.
Member Function Documentation
◆ __call__()
| _base_call.UnaryStreamCall grpc.aio._base_channel.UnaryStreamMultiCallable.__call__ | ( | self, | |
| Any | request, | ||
| *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 server-streaming RPC.
Asynchronously invokes the underlying RPC.
Args:
request: The request value 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 UnaryStreamCall 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 71 of file _base_channel.py.
The documentation for this class was generated from the following file: