Public Member Functions | |
def | __call__ (self, request_iterator, timeout=None, metadata=None, credentials=None, wait_for_ready=None, compression=None) |
Affords invoking a stream-stream RPC on client-side.
Definition at line 904 of file src/python/grpcio/grpc/__init__.py.
def grpc.StreamStreamMultiCallable.__call__ | ( | self, | |
request_iterator, | |||
timeout = None , |
|||
metadata = None , |
|||
credentials = None , |
|||
wait_for_ready = None , |
|||
compression = None |
|||
) |
Invokes the underlying RPC on the client. Args: request_iterator: An iterator that yields request values for the RPC. timeout: An optional duration of time in seconds to allow for the RPC. If not specified, the timeout is considered infinite. 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: An object that is a Call for the RPC, an iterator of response values, and a Future for the RPC. Drawing response values from the returned Call-iterator may raise RpcError indicating termination of the RPC with non-OK status.
Reimplemented in grpc._channel._StreamStreamMultiCallable, and grpc._interceptor._StreamStreamMultiCallable.
Definition at line 908 of file src/python/grpcio/grpc/__init__.py.