sark-core 0.21.0

Fiber-free request, route, dispatch, and lifecycle core for Sark
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

//! Disabled lifecycle observation.

use std::convert::Infallible;

use o3::buffer::hold::evidence;

use crate::{
    body::credit,
    life,
    life::{endpoint, exchange, sequence},
};

#[derive(Clone, Copy, Default)]
pub struct Disabled;

impl<C: Copy, S: Copy> life::Mode<C, S> for Disabled {
    const ENABLED: bool = false;

    type Retention = evidence::Off;
    type Observer = Infallible;

    type Body<'a>
        = credit::Disabled
    where
        Self: 'a,
        C: 'a,
        S: 'a;

    fn observer(&mut self) -> Option<&mut Self::Observer> {
        None
    }

    fn body<'a>(&'a mut self, _: exchange::Id<C, S>) -> Self::Body<'a>
    where
        C: 'a,
        S: 'a,
    {
        credit::Disabled::new()
    }
}

impl<E, O> endpoint::Mode<E, O> for Disabled {
    const ENABLED: bool = false;

    type Observer = Infallible;

    fn observer(&mut self) -> Option<&mut Self::Observer> {
        None
    }
}

impl<C: Copy> sequence::Mode<C> for Disabled {
    type Session = ();
    type TransportTag = ();
    type Trace = Infallible;

    fn trace(&self) -> Option<&Self::Trace> {
        None
    }

    fn trace_mut(&mut self) -> Option<&mut Self::Trace> {
        None
    }
}