interprocess 1.0.0

Interprocess communication toolkit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use futures::{
    io::{BufReader, AsyncBufReadExt, AsyncWriteExt},
    stream::TryStreamExt,
};
use interprocess::nonblocking::local_socket::*;

#[tokio::main]
async fn main() {
    let listener = LocalSocketListener::bind("/tmp/example.sock")
        .await
        .unwrap();
    listener
        .incoming()
        .try_for_each(|mut conn| async move {
            conn.write_all(b"Hello from server!\n").await.unwrap();
            let mut conn = BufReader::new(conn);
            let mut buffer = String::new();
            conn.read_line(&mut buffer).await.unwrap();
            println!("Client answered: {}", buffer);
            Ok(())
        })
        .await
        .unwrap();
}