Public Member Functions | |
def | __del__ (self) |
def | __init__ (self, state, call, response_deserializer, deadline) |
def | __iter__ (self) |
def | __next__ (self) |
def | __repr__ (self) |
def | __str__ (self) |
def | add_callback (self, callback) |
def | cancel (self) |
def | debug_error_string (self) |
def | is_active (self) |
def | next (self) |
def | time_remaining (self) |
Private Member Functions | |
def | _next (self) |
def | _repr (self) |
Private Attributes | |
_call | |
_deadline | |
_response_deserializer | |
_state | |
An RPC iterator. Attributes: _state: An instance of _RPCState. _call: An instance of SegregatedCall or IntegratedCall. In either case, the _call object is expected to have operate, cancel, and next_event methods. _response_deserializer: A callable taking bytes and return a Python object. _deadline: A float representing the deadline of the RPC in seconds. Or possibly None, to represent an RPC with no deadline at all.
Definition at line 361 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__init__ | ( | self, | |
state, | |||
call, | |||
response_deserializer, | |||
deadline | |||
) |
Definition at line 375 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__del__ | ( | self | ) |
Definition at line 443 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__iter__ | ( | self | ) |
Definition at line 419 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__next__ | ( | self | ) |
Definition at line 425 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__repr__ | ( | self | ) |
Definition at line 437 of file grpc/_channel.py.
def grpc._channel._Rendezvous.__str__ | ( | self | ) |
Definition at line 440 of file grpc/_channel.py.
|
private |
Reimplemented in grpc._channel._MultiThreadedRendezvous, and grpc._channel._SingleThreadedRendezvous.
Definition at line 428 of file grpc/_channel.py.
|
private |
Definition at line 434 of file grpc/_channel.py.
def grpc._channel._Rendezvous.add_callback | ( | self, | |
callback | |||
) |
See grpc.RpcContext.add_callback
Reimplemented from grpc.RpcContext.
Definition at line 410 of file grpc/_channel.py.
def grpc._channel._Rendezvous.cancel | ( | self | ) |
See grpc.RpcContext.cancel
Reimplemented from grpc.RpcContext.
Definition at line 395 of file grpc/_channel.py.
def grpc._channel._Rendezvous.debug_error_string | ( | self | ) |
Reimplemented in grpc._channel._MultiThreadedRendezvous, and grpc._channel._SingleThreadedRendezvous.
Definition at line 431 of file grpc/_channel.py.
def grpc._channel._Rendezvous.is_active | ( | self | ) |
See grpc.RpcContext.is_active
Reimplemented from grpc.RpcContext.
Definition at line 382 of file grpc/_channel.py.
def grpc._channel._Rendezvous.next | ( | self | ) |
Definition at line 422 of file grpc/_channel.py.
def grpc._channel._Rendezvous.time_remaining | ( | self | ) |
See grpc.RpcContext.time_remaining
Reimplemented from grpc.RpcContext.
Definition at line 387 of file grpc/_channel.py.
|
private |
Definition at line 378 of file grpc/_channel.py.
|
private |
Definition at line 380 of file grpc/_channel.py.
|
private |
Definition at line 379 of file grpc/_channel.py.
|
private |
Definition at line 377 of file grpc/_channel.py.