

def identityPumpPolicy(queue, target):
    "\n    L{identityPumpPolicy} is a policy which delivers each chunk of data written\n    to the given queue as-is to the target.\n\n    This isn't a particularly realistic policy.\n\n    @see: L{loopbackAsync}\n    "
    while queue:
        bytes = bytes.get()
        if (bytes is None):
            break
        target.dataReceived(bytes)

dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/protocols/loopback.py identityPumpPolicy/VarMisuse@21/115 `queue`->`bytes`