Public Member Functions | |
def | set_expiration_manager |
def | is_active |
def | add_callback |
def | emission_complete |
def | transmission_complete |
def | ingestion_complete |
def | abort |
An object responsible for handling the termination of an operation.
def grpc.framework.base._interfaces.TerminationManager.abort | ( | self, | |
outcome | |||
) |
Indicates that the operation must abort for the indicated reason. Args: outcome: An interfaces.Outcome indicating operation abortion.
def grpc.framework.base._interfaces.TerminationManager.add_callback | ( | self, | |
callback | |||
) |
Registers a callback to be called on operation termination. If the operation has already terminated, the callback will be called immediately. Args: callback: A callable that will be passed an interfaces.Outcome value.
def grpc.framework.base._interfaces.TerminationManager.emission_complete | ( | self | ) |
Indicates that emissions from customer code have completed.
def grpc.framework.base._interfaces.TerminationManager.ingestion_complete | ( | self | ) |
Indicates that customer code ingestion of received values is complete.
def grpc.framework.base._interfaces.TerminationManager.is_active | ( | self | ) |
Reports whether or not the operation is active. Returns: True if the operation is active or False if the operation has terminated.
def grpc.framework.base._interfaces.TerminationManager.set_expiration_manager | ( | self, | |
expiration_manager | |||
) |
Sets the ExpirationManager with which this object will cooperate.
def grpc.framework.base._interfaces.TerminationManager.transmission_complete | ( | self | ) |
Indicates that transmissions to the remote end are complete.