
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.