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

def test_registerProducer(self):

    wrapper = self._getWrapper()
    producer = object()
    wrapper.registerProducer(producer, True)
    self.assertIs(wrapper.transport.producer, producer)
    self.assertTrue(wrapper.transport.streaming)
