dope-session 0.2.1

Thin io_uring adaptor with "Manifolds"
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

use crate::CodecLayer;
use crate::SlotId;
use crate::session::Egress;
use dambi::Bytes;

pub trait ClientFramer: 'static {
    type Head;

    fn parse(&mut self, buf: &Bytes) -> Option<(Self::Head, usize)>;
}

pub trait ClientProtocol: 'static {
    type Framer: ClientFramer + Default + 'static;
    type ConnState: Default + 'static;
    type CodecLayer: CodecLayer;

    fn on_connect(
        &mut self,
        conn_id: SlotId,
        conn_state: &mut Self::ConnState,
        out: Egress<'_, Self::CodecLayer>,
    ) {
        let _ = (conn_id, conn_state, out);
    }

    fn on_response(
        &mut self,
        conn_id: SlotId,
        conn_state: &mut Self::ConnState,
        head: <Self::Framer as ClientFramer>::Head,
        out: Egress<'_, Self::CodecLayer>,
    );

    fn wants_close(&self, conn_state: &Self::ConnState) -> bool {
        let _ = conn_state;
        false
    }

    fn on_disconnect(
        &mut self,
        conn_id: SlotId,
        conn_state: &mut Self::ConnState,
        out: Egress<'_, Self::CodecLayer>,
    ) {
        let _ = (conn_id, conn_state, out);
    }
}