src/types/bind.rs


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

use super::Endpoint;
use std::error::Error;

pub trait Reader<E: Endpoint>: Send + Sync {
    type Error: Error;

    fn read(&self, buf: &mut [u8]) -> Result<(usize, E), Self::Error>;
}

pub trait Writer<E: Endpoint>: Send + Sync + Clone + 'static {
    type Error: Error;

    fn write(&self, buf: &[u8], dst: &E) -> Result<(), Self::Error>;
}

pub trait Bind: Send + Sync + 'static {
    type Error: Error;
    type Endpoint: Endpoint;

    /* Until Rust gets type equality constraints these have to be generic */
    type Writer: Writer<Self::Endpoint>;
    type Reader: Reader<Self::Endpoint>;

    /* Used to close the reader/writer when binding to a new port */
    type Closer;

    fn bind(port: u16) -> Result<(Self::Reader, Self::Writer, Self::Closer, u16), Self::Error>;
}