'When the streaming producer is paused and then resumed, the underlying
producer starts getting resumeProducing calls again after the resume.
The test will never finish (or rather, time out) if the resume
producing call is not working.'

def test_resume(self):

    class PausingStringTransport(StringTransport, ):
        writes = 0
        def write(self, data):
            self.writes += 1
            StringTransport.write(self, data)
            if (self.writes == 3):
                self.producer.pauseProducing()
                self.producer.resumeProducing()
    consumer = PausingStringTransport()
    return self.streamUntilEnd(consumer)
