def _produce():
    if self._producer:
        self._producer.resumeProducing()
        self._reactor.callLater(0.1, _produce)
def _produce():
    if self._producer:
        self._producer.resumeProducing()
        self._reactor.callLater(0.1, _produce)