dope-session 0.2.0

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

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;

    fn on_connect(&mut self, conn_id: SlotId, conn_state: &mut Self::ConnState, out: Egress<'_>) {
        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<'_>,
    );

    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) {
        let _ = (conn_id, conn_state);
    }
}