sark-core 0.29.1

Fiber-free request, route, dispatch, and lifecycle core 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

use o3::buffer::{resident, segments};
use sark_http::{payload::owned, request::body};

/// A retained backing converted without copying or changing its owner lifetime.
pub trait Store<'d>: Sized {
    type Output: body::Source<'d>;

    fn finish(storage: Option<Self>) -> Self::Output;
}

impl<'d> Store<'d> for owned::Segments<'d> {
    type Output = Self;

    fn finish(storage: Option<Self>) -> Self {
        match storage {
            Some(storage) => storage,
            None => Self::new(),
        }
    }
}

impl<'d> Store<'d> for segments::Chain<resident::Shared<'d>> {
    type Output = owned::Segments<'d>;

    fn finish(storage: Option<Self>) -> Self::Output {
        match storage {
            Some(storage) => storage.into(),
            None => owned::Segments::new(),
        }
    }
}

impl<'d> Store<'d> for &[u8] {
    type Output = Self;

    fn finish(storage: Option<Self>) -> Self {
        match storage {
            Some(storage) => storage,
            None => &[],
        }
    }
}

impl<'d> Store<'d> for () {
    type Output = owned::Segments<'d>;

    fn finish(_: Option<Self>) -> Self::Output {
        owned::Segments::new()
    }
}