sark-h2 0.25.0

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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use o3::mem::Rejected;
use sark_core::{
    body::{self, admit},
    decode::{request, state},
    manifold::stream::Boundary,
    request::Head,
};
use sark_http::field::metadata::packed;

use crate::server::service::Prepared;

#[doc(hidden)]
pub struct Selected {
    head: Head<packed::Decoded>,
    body: admit::Plan,
}

impl Selected {
    pub(super) const fn new(head: Head<packed::Decoded>, body: admit::Plan) -> Self {
        Self { head, body }
    }

    pub(super) const fn plan(len: admit::Length) -> admit::Plan {
        admit::Plan::new(
            admit::Retention::Retained,
            usize::MAX,
            len,
            admit::Stream::Buffered,
        )
    }
}

impl request::Head for Selected {
    type Prepared = Prepared;
    type Start = request::Plain<state::Uniform<Prepared, state::Routed>>;

    fn try_start(
        self,
        limit: usize,
        boundary: Boundary,
    ) -> Result<Self::Start, Rejected<Self, body::Error>> {
        let Self { head, body } = self;
        match body.try_start(limit, boundary) {
            Ok(admit::Start::Open(body)) => Ok(request::Plain::new(state::Uniform::new(
                Prepared::new(head),
                request::Body::Open(body),
            ))),
            Ok(admit::Start::Finished(body)) => Ok(request::Plain::new(state::Uniform::new(
                Prepared::new(head),
                request::Body::Finished(body),
            ))),
            Err(error) => Err(Rejected::new(Self { head, body }, error)),
        }
    }
}