afnative 0.1.3

afnative provides an abstraction for operating-system-specific sockets like Unix sockets and Windows named pipes.
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use std::{
    io::{Read, Write},
    os::unix::net::{UnixListener, UnixStream},
    path::Path,
};

pub struct Listener(UnixListener);

impl Listener {
    pub fn bind(path: &Path) -> Result<Self, std::io::Error> {
        let unix_listener = UnixListener::bind(path)?;

        Ok(Self(unix_listener))
    }
}

impl crate::Listener for Listener {
    fn accept(&mut self) -> std::io::Result<Box<dyn crate::Conn>> {
        let stream = self.0.accept()?;

        Ok(Box::new(Conn(stream.0)))
    }
}

pub struct Conn(UnixStream);

impl Conn {
    pub fn dial(path: &Path) -> Result<Self, std::io::Error> {
        let stream = UnixStream::connect(path)?;

        Ok(Self(stream))
    }
}

impl crate::Conn for Conn {}

impl Read for Conn {
    fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
        self.0.read(buf)
    }
}

impl Write for Conn {
    fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
        self.0.write(buf)
    }

    fn flush(&mut self) -> std::io::Result<()> {
        self.0.flush()
    }
}