U gY@sddlmZddlZddlmZddlmZmZmZddl Z ddl m Z m Z er\ddl mZGdddeZed ed Zzdd l mZd ZWnek rd ZYnXed ddddZdddddZdS)) annotationsN)contextmanager) TYPE_CHECKINGProtocolTypeVar) SOCK_STREAMsocket) Generatorc@seZdZddddZdS)ClosableNone)returncCsdSN)selfrrD/tmp/pip-unpacked-wheel-ks04xdmi/trio/_highlevel_open_unix_stream.pyclosezClosable.closeN)__name__ __module__ __qualname__rrrrrr sr CloseT)bound)AF_UNIXTFzGenerator[CloseT, None, None])objr ccs&z |VWn|YnXdSr )r)rrrrclose_on_errors  rz3str | bytes | os.PathLike[str] | os.PathLike[bytes]ztrio.SocketStream)filenamer c sJts tdttt}t||t|IdHW5QRXt |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 RuntimeErrorrrrrconnectosfspathtrioZ SocketStream)rsockrrropen_unix_socket&s    r#) __future__rr contextlibrtypingrrrr!Z trio.socketrrcollections.abcr r rrr ImportErrorrr#rrrrs"