Struct Listener 

pub struct Listener { /* private fields */ }

Listens for incoming qmux connections on a Unix domain socket.

Each accepted connection yields the session plus the peer’s PeerCred, so the caller can enforce a uid/gid/pid allowlist. The socket file is removed on drop.

Implementations

impl Listener

pub async fn bind(path: impl AsRef<Path>) -> Result<Self, Error>

Bind a Unix socket at path, replacing a stale socket file left by a previous run.

Refuses to unlink the path if it exists and is not a socket, to avoid clobbering an unrelated file.

pub fn with_protocols<I, S>(self, protocols: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Advertise these application protocols (moq ALPNs) for in-band negotiation, in preference order. The first server entry the client also offers wins.

pub fn set_mode(&self, mode: u32) -> Result<(), Error>

Set the socket file’s permission bits (e.g. 0o660).

pub fn path(&self) -> &Path

The bound socket path.

pub async fn accept(&self) -> Option<Result<(Session, PeerCred), Error>>

Accept the next connection, returning the session and the peer’s credentials.

Returns None only if the listener itself is gone; a per-connection failure is yielded as Some(Err(..)) so the accept loop keeps running.

Trait Implementations

impl Drop for Listener

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.