o ҷhY@sddlmZddlZddlmZddlmZmZmZddl Z ddl m Z m Z er.ddl mZGdddeZed ed Zz dd l mZd ZWn eyQd ZYnwedddZdddZdS)) annotationsN)contextmanager) TYPE_CHECKINGProtocolTypeVar) SOCK_STREAMsocket) Generatorc@seZdZdddZdS)ClosablereturnNonecCsdSN)selfrrS/var/www/html/venv/lib/python3.10/site-packages/trio/_highlevel_open_unix_stream.pycloseszClosable.closeN)r r )__name__ __module__ __qualname__rrrrrr sr CloseT)bound)AF_UNIXTFobjr Generator[CloseT, None, None]ccs z|VWdS|r )r)rrrrclose_on_errors  rfilename3str | bytes | os.PathLike[str] | os.PathLike[bytes]trio.SocketStreamcs`tstdttt}t||t|IdHWdn1s&wYt |S)aOpens a connection to the specified `Unix domain socket `__. You must have read/write permission on the specified file to connect. Args: filename (str or bytes): The filename to open the connection to. Returns: SocketStream: a :class:`~trio.abc.Stream` connected to the given file. Raises: OSError: If the socket file could not be connected to. RuntimeError: If AF_UNIX sockets are not supported. z/Unix sockets are not supported on this platformN) has_unix RuntimeErrorrrrrconnectosfspathtrio SocketStream)rsockrrropen_unix_socket&s   r&)rrr r)rrr r) __future__rr! contextlibrtypingrrrr# trio.socketrrcollections.abcr r rrr ImportErrorrr&rrrrs&