dope-uring 0.28.1

Owned io_uring backend for dope
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

use dope_sys::io::reactor::complete::{
    self,
    packet::{record, record::Selection},
};

use crate::reactor::cq::{Flags, Outcome};

pub struct Decoded<K, E, B> {
    parts: complete::Parts<K, Outcome, Flags>,
    buffer: Selection<B, E>,
}

impl<K, E, B> complete::Map for Decoded<K, E, B> {
    type Entry<T> = Decoded<K, E, T>;

    fn map<T, U>(entry: Self::Entry<T>, map: impl FnOnce(T) -> U) -> Self::Entry<U> {
        Decoded {
            parts: entry.parts,
            buffer: match entry.buffer {
                Selection::None => Selection::None,
                Selection::Selected(buffer) => Selection::Selected(map(buffer)),
                Selection::Invalid(fault) => Selection::Invalid(fault),
            },
        }
    }
}

impl<K: Copy, E, B> record::Map for Decoded<K, E, B> {
    type Parts = complete::Parts<K, Outcome, Flags>;
    type Fault = E;

    fn new<T>(parts: Self::Parts, buffer: Selection<T, E>) -> Self::Entry<T> {
        Decoded { parts, buffer }
    }

    fn into_parts<T>(entry: Self::Entry<T>) -> (Self::Parts, Selection<T, E>) {
        (entry.parts, entry.buffer)
    }
}