[−][src]Module romio::uds
Async UDS (Unix Domain Sockets) bindings.
Example
#![feature(async_await, await_macro, futures_api)] use romio::uds::{UnixListener, UnixStream}; use futures::prelude::*; async fn say_hello(mut stream: UnixStream) { await!(stream.write_all(b"Shall I hear more, or shall I speak at this?!")); } 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) = await!(incoming.next()) { await!(say_hello(stream?)); } 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. |