Public Member Functions | |
def | __init__ |
def | set_ingestion_and_expiration_managers |
def | inmit |
def | abort |
![]() | |
def | set_ingestion_and_expiration_managers |
![]() | |
def | inmit |
def | abort |
A TransmissionManager implementation that sends tickets.
def grpc.framework.base._transmission._TransmittingTransmissionManager.__init__ | ( | self, | |
lock, | |||
pool, | |||
callback, | |||
operation_id, | |||
ticketizer, | |||
termination_manager | |||
) |
A TransmissionManager implementation that sends tickets.
Constructor. Args: lock: The operation-servicing-wide lock object. pool: A thread pool in which the work of transmitting tickets will be performed. callback: A callable that accepts tickets and sends them to the other side of the operation. operation_id: The operation's ID. ticketizer: A _Ticketizer for ticket creation. termination_manager: The _interfaces.TerminationManager associated with this operation.
def grpc.framework.base._transmission._TransmittingTransmissionManager.abort | ( | self, | |
outcome | |||
) |
See _interfaces.TransmissionManager.abort for specification.
def grpc.framework.base._transmission._TransmittingTransmissionManager.inmit | ( | self, | |
emission, | |||
complete | |||
) |
See _interfaces.TransmissionManager.inmit for specification.
def grpc.framework.base._transmission._TransmittingTransmissionManager.set_ingestion_and_expiration_managers | ( | self, | |
ingestion_manager, | |||
expiration_manager | |||
) |
See overridden method for specification.