'L{identityPumpPolicy} is a pump policy which calls the target\'s
C{dataReceived} method one for each string in the queue passed to it.'

def test_identityPumpPolicy(self):

    bytes = []
    client = Protocol()
    client.dataReceived = bytes.append
    queue = loopback._LoopbackQueue()
    queue.put('foo')
    queue.put('bar')
    queue.put(None)
    loopback.identityPumpPolicy(queue, client)
    self.assertEqual(bytes, ['foo', 'bar'])
