'Repeatedly prod a non-streaming producer to produce data.'

def prodProducer(self):

    self.openCall = None
    if (self.myproducer is not None):
        self.openCall = reactor.callLater(0, self.prodProducer)
        self.myproducer.resumeProducing()
