Struct SocketIncoming

pub struct SocketIncoming { /* private fields */ }

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.

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

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

Formats the value using the given formatter.

impl From<UnixListener> for SocketIncoming

fn from(listener: UnixListener) -> Self

Converts to this type from the input type.

impl<'pin> Unpin for SocketIncoming

where __SocketIncoming<'pin>: Unpin,