[−][src]Module romio::uds
Async UDS (Unix Domain Sockets) bindings.
Example
use romio::uds::{UnixListener, UnixStream}; use futures::prelude::*; async fn say_hello(mut stream: UnixStream) { stream.write_all(b"Shall I hear more, or shall I speak at this?!").await; } async fn listen() -> Result<(), Box<dyn std::error::Error + 'static>> { let listener = UnixListener::bind("/tmp/sock")?; let mut incoming = listener.incoming(); // accept connections and process them serially while let Some(stream) = incoming.next().await { say_hello(stream?).await; } Ok(()) }
Structs
ConnectFuture | Future returned by |
Incoming | Stream of listeners |
UCred | Credentials of a process |
UnixDatagram | An I/O object representing a Unix datagram socket. |
UnixListener | A Unix socket which can accept connections from other Unix sockets. |
UnixStream | A structure representing a connected Unix socket. |