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 2022-11-17 13:13:24.

asynqueue.iteration.IterationProducer(object) class documentation

`asynqueue.iteration.IterationProducer(object)` class documentation