sark-h2 0.28.1

Fiber-free HTTP/2 protocol primitives and manifold server for sark
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

use sark_core::decode::{exec, request, state};

use crate::server::{payload::Buffer, state::exchange::Accepted};

pub(crate) struct Sync<'d, P>
where
    P: request::Synchronous,
{
    request: <P::Family as state::Family<P>>::State<Accepted<'d>>,
}

impl<'d, P> Sync<'d, P>
where
    P: request::Synchronous,
{
    pub(crate) const fn new(request: <P::Family as state::Family<P>>::State<Accepted<'d>>) -> Self {
        Self { request }
    }

    pub(crate) fn take(self) -> request::Body<request::Admitted<exec::Sync, P, Buffer<'d>>> {
        <P::Family as state::Homogeneous<P, exec::Sync>>::fold(self.request, Take)
    }
}

struct Take;

impl<'d, P> exec::Fold<P, Accepted<'d>, exec::Sync> for Take
where
    P: request::Synchronous,
{
    type Output = request::Body<request::Admitted<exec::Sync, P, Buffer<'d>>>;

    fn open<S: state::Slot<P>>(self, slot: S, body: Buffer<'d>) -> Self::Output {
        request::Body::Open(slot.admit(body))
    }

    fn finished<S: state::Slot<P>>(self, slot: S, body: Buffer<'d>) -> Self::Output {
        request::Body::Finished(slot.admit(body))
    }
}