'Implement L{IStreamClientEndpoint.connect} to connect via a
UNIX Socket'

def connect(self, protocolFactory):

    try:
        wf = _WrappingFactory(protocolFactory)
        self._reactor.connectUNIX(self._path, wf, timeout=self._timeout, checkPID=self._checkPID)
        return wf._onConnection
    except:
        return defer.fail()
