def loopbackUNIX(server, client, noisy=True):
 path = tempfile.mktemp()
 from twisted.internet import reactor
 f = policies.WrappingFactory(protocol.Factory())
 serverWrapper = _FireOnClose(f, server)
 f.noisy = noisy
 f.buildProtocol = (lambda addr: serverWrapper)
 serverPort = reactor.listenUNIX(path, f)
 clientF = LoopbackClientFactory(client)
 clientF.noisy = noisy
 reactor.connectUNIX(path, clientF)
 d = clientF.deferred
 d.addCallback((lambda x: serverWrapper.deferred))
 d.addCallback((lambda x: serverPort.stopListening()))
 return d

def loopbackUNIX ( server , client , noisy = True ) : path = tempfile . mktemp ( ) from twisted . internet import reactor f = policies . WrappingFactory ( protocol . Factory ( ) ) serverWrapper = _FireOnClose ( f , server ) f . noisy = noisy f . buildProtocol = ( lambda addr : serverWrapper ) serverPort = reactor . listenUNIX ( path , f ) clientF = LoopbackClientFactory ( client ) clientF . noisy = noisy reactor . connectUNIX ( path , clientF ) d = clientF . deferred d . addCallback ( ( lambda x : serverWrapper . deferred ) ) d . addCallback ( ( lambda x : serverPort . stopListening ( ) ) ) return d
run session between server and client protocol instances over unix socket .