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
25
26
27
28
29
30
31
32
33

use interprocess::local_socket::{LocalSocketListener, LocalSocketStream};
use std::{
    io::{self, prelude::*, BufReader},
    error::Error,
};

fn main() -> Result<(), Box<dyn Error>> {
    fn handle_error(
        connection: io::Result<LocalSocketStream>,
    ) -> Option<LocalSocketStream> {
        match connection {
            Ok(val) => Some(val),
            Err(error) => {
                panic!("Incoming connection failed: {}", error);
            }
        }
    }

    let listener = LocalSocketListener::bind("/tmp/example.sock")?;
    for mut conn in listener.incoming().filter_map(handle_error) {
        println!("Incoming connection!");
        
        conn.write_all(b"Hello from server!\n")?;

        // Add buffering to the connection to read a line.
        let mut conn = BufReader::new(conn);
        let mut buffer = String::new();
        conn.read_line(&mut buffer)?;

        println!("Client answered: {}", buffer);
    }
    Ok(())
}