grpc._interceptor._StreamUnaryMultiCallable Class Reference

Inheritance diagram for grpc._interceptor._StreamUnaryMultiCallable:

Public Member Functions
def	__call__ (self, request_iterator, timeout=None, metadata=None, credentials=None, wait_for_ready=None, compression=None)
def	__init__ (self, thunk, method, interceptor)
def	future (self, request_iterator, timeout=None, metadata=None, credentials=None, wait_for_ready=None, compression=None)
def	with_call (self, request_iterator, timeout=None, metadata=None, credentials=None, wait_for_ready=None, compression=None)

Private Member Functions
def	_with_call (self, request_iterator, timeout=None, metadata=None, credentials=None, wait_for_ready=None, compression=None)

Private Attributes
	_interceptor
	_method
	_thunk

Detailed Description

Definition at line 341 of file _interceptor.py.

Constructor & Destructor Documentation

__init__()

def grpc._interceptor._StreamUnaryMultiCallable.__init__	(		self,
			thunk,
			method,
			interceptor
	)

Definition at line 343 of file _interceptor.py.

Member Function Documentation

__call__()

def grpc._interceptor._StreamUnaryMultiCallable.__call__	(		self,
			request_iterator,
			timeout = None,
			metadata = None,
			credentials = None,
			wait_for_ready = None,
			compression = None
	)

Synchronously invokes the underlying RPC.

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 None, 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:
  The response value for the RPC.

Raises:
  RpcError: Indicating that the RPC terminated with non-OK status. The
    raised RpcError will also implement grpc.Call, affording methods
    such as metadata, code, and details.

Reimplemented from grpc.StreamUnaryMultiCallable.

Definition at line 348 of file _interceptor.py.

_with_call()

def grpc._interceptor._StreamUnaryMultiCallable._with_call (   self,   request_iterator,   timeout = None,   metadata = None,   credentials = None,   wait_for_ready = None,   compression = None  )

private

Definition at line 363 of file _interceptor.py.

future()

def grpc._interceptor._StreamUnaryMultiCallable.future	(		self,
			request_iterator,
			timeout = None,
			metadata = None,
			credentials = None,
			wait_for_ready = None,
			compression = None
	)

Asynchronously 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 None, 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 both a Call for the RPC and a Future.
    In the event of RPC completion, the return Call-Future's result value
    will be the response message of the RPC. Should the event terminate
    with non-OK status, the returned Call-Future's exception value will
    be an RpcError.

Reimplemented from grpc.StreamUnaryMultiCallable.

Definition at line 412 of file _interceptor.py.

with_call()

def grpc._interceptor._StreamUnaryMultiCallable.with_call	(		self,
			request_iterator,
			timeout = None,
			metadata = None,
			credentials = None,
			wait_for_ready = None,
			compression = None
	)

Synchronously 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 None, 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:
  The response value for the RPC and a Call object for the RPC.

Raises:
  RpcError: Indicating 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.

Reimplemented from grpc.StreamUnaryMultiCallable.

Definition at line 398 of file _interceptor.py.

Member Data Documentation

_interceptor

grpc._interceptor._StreamUnaryMultiCallable._interceptor

private

Definition at line 346 of file _interceptor.py.

_method

grpc._interceptor._StreamUnaryMultiCallable._method

private

Definition at line 345 of file _interceptor.py.

_thunk

grpc._interceptor._StreamUnaryMultiCallable._thunk

private

Definition at line 344 of file _interceptor.py.

---

The documentation for this class was generated from the following file:

• _interceptor.py