interprocess 1.0.0

Interprocess communication toolkit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

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

#[tokio::main]
async fn main() {
    // Replace the path as necessary on Windows.
    let mut conn = LocalSocketStream::connect("/tmp/example.sock")
        .await
        .unwrap();
    conn.write_all(b"Hello from client!\n").await.unwrap();
    let mut conn = BufReader::new(conn);
    let mut buffer = String::new();
    conn.read_line(&mut buffer).await.unwrap();
    println!("Server answered: {}", buffer);
}