def _produce():
    d = self.producer.resumeProducing()
    d.addCallback((lambda x: self._reactor.callLater(0.1, _produce)))
def _produce():
    d = self.producer.resumeProducing()
    d.addCallback((lambda x: self._reactor.callLater(0.1, _produce)))