a.i.IterationProducer(object) : class documentation

Part of asynqueue.iteration View In Hierarchy Source for iteration.py Main doc for AsynQueue

Implements interfaces: twisted.internet.interfaces.IPushProducer

Producer of iterations from a Deferator.

I am a producer of iterations from a Deferator. Get me running with a call to run, which returns a deferred that fires when I'm done iterating or when the consumer has stopped me, whichever comes first.

Method __init__ Undocumented
Method deferUntilDone Returns a deferred that fires (with a reference to my consumer) when I am done producing iterations.
Method registerConsumer How could we push to a consumer without knowing what it is?
Method run Produces my iterations, returning a Deferred that fires (with a reference to my consumer) when done.
Method pauseProducing IPushProducer implementation.
Method resumeProducing IPushProducer implementation.
Method stopProducing IPushProducer implementation.
def __init__(self, dr, consumer=None):
Undocumented
def deferUntilDone(self):

Returns a deferred that fires (with a reference to my consumer) when I am done producing iterations.

def registerConsumer(self, consumer):

How could we push to a consumer without knowing what it is?

@defer.inlineCallbacks
def run(self):

Produces my iterations, returning a Deferred that fires (with a reference to my consumer) when done.

def pauseProducing(self):

IPushProducer implementation.

def resumeProducing(self):

IPushProducer implementation.

def stopProducing(self):

IPushProducer implementation.

API Documentation for AsynQueue, generated by pydoctor at 2016-11-16 14:52:11.