An instance of me is constructed by a WireWorkerUniverse on the server end of the AMP connection to run all tasks for its WireServer.

Method	__init__	Undocumented
Method	shutdown	Undocumented
Method	call	Run the f-args-kw combination, in the regular thread or in a thread running if I have one.
Method	getNext	Gets the next item for the iterator specified by ID.
Method	_saveIterator	Undocumented
Method	_call	Undocumented
Method	_getNext	Undocumented

def __init__(self):

Undocumented

def shutdown(self):

Undocumented

def _saveIterator(self, x):

Undocumented

@defer.inlineCallbacks
def _call(self, f, *args, **kw):

Undocumented

def call(self, f, *args, **kw):

Run the f-args-kw combination, in the regular thread or in a thread running if I have one.

Returns A Deferred to the status and result.

@defer.inlineCallbacks
def _getNext(self, ID):

Undocumented

def getNext(self, ID):

Gets the next item for the iterator specified by ID.

Returns a Deferred that fires with a response containing the pickled item and the isValid status indicating if the item is legit (False = StopIteration).

API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.

asynqueue.wire.WireRunner(object) class documentation

`asynqueue.wire.WireRunner(object)` class documentation