#[cfg(windows)]
fn main() -> std::io::Result<()> {
use std::path::PathBuf;
use smol::{io, prelude::*, Async, Unblock};
use tempfile::tempdir;
use uds_windows::{UnixListener, UnixStream};
async fn client(addr: PathBuf) -> io::Result<()> {
let stream = Async::new(UnixStream::connect(addr)?)?;
println!("Connected to {:?}", stream.get_ref().peer_addr()?);
let mut stdout = Unblock::new(std::io::stdout());
io::copy(&stream, &mut stdout).await?;
Ok(())
}
let dir = tempdir()?;
let path = dir.path().join("socket");
smol::block_on(async {
let listener = Async::new(UnixListener::bind(&path)?)?;
println!("Listening on {:?}", listener.get_ref().local_addr()?);
let task = smol::spawn(client(path));
let (stream, _) = listener.read_with(|l| l.accept()).await?;
println!("Accepted a client");
Async::new(stream)?.write_all(b"Hello!\n").await?;
task.await?;
Ok(())
})
}
#[cfg(not(windows))]
fn main() {
println!("This example works only on Windows!");
}