'Stopping the endpoint transport as a producer stops the underlying
process transport.'

def test_stopProducing(self):

    self.endpointTransport.stopProducing()
    self.assertEqual(self.process.producerState, 'stopped')
