def loopbackAsync(server, client, pumpPolicy=identityPumpPolicy):
 serverToClient = _LoopbackQueue()
 clientToServer = _LoopbackQueue()
 server.makeConnection(_LoopbackTransport(serverToClient))
 client.makeConnection(_LoopbackTransport(clientToServer))
 return _loopbackAsyncBody(server, serverToClient, client, clientToServer, pumpPolicy)

def loopbackAsync ( server , client , pumpPolicy = identityPumpPolicy ) : serverToClient = _LoopbackQueue ( ) clientToServer = _LoopbackQueue ( ) server . makeConnection ( _LoopbackTransport ( serverToClient ) ) client . makeConnection ( _LoopbackTransport ( clientToServer ) ) return _loopbackAsyncBody ( server , serverToClient , client , clientToServer , pumpPolicy )
establish a connection between c{server} and c{client} then transfer data between them until the connection is closed .