An AMP server for the remote end of a WireWorker.

Construct me with an endpoint description string and either an instance or the fully qualified name of a WireWorkerUniverse subclass.

Instance Variable service A StreamServerEndpointService from twisted.application.internet that you can include in the application of a .tac file, thus accepting connections to run tasks.
Method __init__ Undocumented
Method start Undocumented
Method stop Undocumented
service =
A StreamServerEndpointService from twisted.application.internet that you can include in the application of a .tac file, thus accepting connections to run tasks.
def __init__(self, description, wwu):
Undocumented
def start(self):
Undocumented
def stop(self):
Undocumented
API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.