def registerProducer(self, producer, streaming):
    self._producer = producer
    self.producerStreaming = streaming

    def _produce():
        if self._producer:
            self._producer.resumeProducing()
            self._reactor.callLater(0.1, _produce)
    if (not streaming):
        self._reactor.callLater(0.0, _produce)
def registerProducer(self, producer, streaming):
    self._producer = producer
    self.producerStreaming = streaming

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