'If a streaming producer is registered after the transport has
disconnected, the producer is not used, and its stopProducing method
is called.'

def test_streamingProducerAfterConnectionLost(self):

    self.registerProducerAfterConnectionLost(True)
