'L{policies.ProtocolWrapper.stopConsuming} calls C{stopConsuming} on
the underlying transport.'

def test_stopConsuming(self):

    wrapper = self._getWrapper()
    result = []
    wrapper.transport.stopConsuming = (lambda : result.append(True))
    wrapper.stopConsuming()
    self.assertEqual(result, [True])
