Struct hyperlocal::SocketIncoming

pub struct SocketIncoming { /* fields omitted */ }

A stream of connections from binding to a socket.

Implementations

impl SocketIncoming

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

Creates a new SocketIncoming binding to provided socket path.

pub fn from_listener(listener: UnixListener) -> Self

Creates a new SocketIncoming from Tokio's UnixListener

let socket = SocketIncoming::from_listener(unix_listener);
let server = Server::builder(socket).serve(service);

Trait Implementations

impl Accept for SocketIncoming

type Conn = UnixStream

The connection type that can be accepted.

type Error = Error

The error type that can occur when accepting a connection.

pub fn poll_accept(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Result<Self::Conn, Self::Error>>>

Poll to accept the next connection.

impl Debug for SocketIncoming

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<UnixListener> for SocketIncoming

pub fn from(listener: UnixListener) -> Self

Performs the conversion.

impl<'pin> Unpin for SocketIncoming where
    __SocketIncoming<'pin>: Unpin,