def identityPumpPolicy(queue, target):
 while queue:
  bytes = queue.get()
  if (bytes is None):
   break
  target.dataReceived(bytes)

def identityPumpPolicy ( queue , target ) : while queue : bytes = queue . get ( ) if ( bytes is None ) : break target . dataReceived ( bytes )
l{identitypumppolicy} is a policy which delivers each chunk of data written to the given queue as-is to the target .