sark-core 0.26.2

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

use crate::{deadline, life};

#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct Id<C, S> {
    connection: C,
    stream: S,
}

impl<C, S> Id<C, S> {
    pub const fn new(conn: C, stream: S) -> Self {
        Self {
            connection: conn,
            stream,
        }
    }
}

impl<C: Copy, S: Copy> Id<C, S> {
    pub const fn connection(self) -> C {
        self.connection
    }

    pub const fn stream(self) -> S {
        self.stream
    }

    pub fn begin_expiry<M: life::Mode<C, S>>(
        self,
        mode: &mut M,
        phase: deadline::Phase,
    ) -> life::Expiry<C, S> {
        mode.observe(life::Event::ExchangeDeadlineExpired {
            exchange: self,
            phase,
        });
        life::Expiry::new(self, phase)
    }

    pub fn retire<M: life::Mode<C, S>>(self, mode: &mut M, outcome: life::Outcome) {
        mode.observe(life::Event::RequestOwnerScopeClosed(self));
        mode.observe(life::Event::Terminal {
            exchange: self,
            outcome,
        });
        mode.observe(life::Event::ExchangeRetired(self));
    }
}