'Pausing the endpoint transport pauses the underlying process transport.'

def test_pauseProducing(self):

    self.endpointTransport.pauseProducing()
    self.assertEqual(self.process.producerState, 'paused')
