'If the underlying transport tells its producer to stopProducing(),
this is passed on to the high-level producer.'

def test_streamingProducerStopProducing(self):

    (_, tlsProtocol, producer) = self.setupStreamingProducer()
    tlsProtocol.transport.producer.stopProducing()
    self.assertEqual(producer.producerState, 'stopped')
