asynkit 0.1.0

Abstractions for runtime-independent crates
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

use std::{io, net::SocketAddr};

use crate::Runtime;

pub type TcpStreamOf<R> = <<R as Runtime>::Tcp as Tcp>::Stream;
pub type TcpStreamReadOf<R> = <<<R as Runtime>::Tcp as Tcp>::Stream as Stream>::Read;
pub type TcpStreamWriteOf<R> = <<<R as Runtime>::Tcp as Tcp>::Stream as Stream>::Write;
pub type TcpListenerOf<R> = <<R as Runtime>::Tcp as Tcp>::Listener;

pub trait Tcp {
    type Listener: Listener<Self::Stream>;
    type Stream: Stream;

    fn stream(addr: impl Into<SocketAddr>) -> impl Future<Output = io::Result<Self::Stream>>;
    fn listener(addr: impl Into<SocketAddr>) -> impl Future<Output = io::Result<Self::Listener>>;
}

pub trait Listener<S: Stream> {
    fn accept(&self) -> impl Future<Output = io::Result<(S, SocketAddr)>>;
}

pub trait Stream: Read + Write + State {
    type Read: Read;
    type Write: Write;

    fn split(self) -> (Self::Read, Self::Write);
}

pub trait Read: State {
    fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> impl Future<Output = io::Result<usize>> + 'a;
}

pub trait Write: State {
    fn write_all<'a>(&'a mut self, buf: &'a [u8]) -> impl Future<Output = io::Result<()>> + 'a;
}

pub trait State {
    fn local_addr(&self) -> io::Result<SocketAddr>;
    fn peer_addr(&self) -> io::Result<SocketAddr>;
}