oxidized 0.1.0

A hyper-performant, modular, and asynchronous web framework for Rust, built on hyper and tokio. Featuring a Tower-inspired, Service-based architecture for maximum performance and composability.
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

use http_body_util::BodyExt;
use hyper::body::Incoming;
use hyper::{HeaderMap, Method, Uri};

pub struct Request {
    inner: hyper::Request<Incoming>,
}

pub struct RequestParts {
    pub method: Method,
    pub uri: Uri,
    pub headers: HeaderMap,
}

pub type Body = hyper::body::Incoming;

impl Request {
    pub fn from_hyper(req: hyper::Request<Incoming>) -> Self {
        Self { inner: req }
    }

    pub fn into_parts(self) -> (RequestParts, Body) {
        let (parts, body) = self.inner.into_parts();
        let request_parts = RequestParts {
            method: parts.method,
            uri: parts.uri,
            headers: parts.headers,
        };
        (request_parts, body)
    }

    pub fn inner(&self) -> &hyper::Request<Incoming> {
        &self.inner
    }

    pub fn inner_mut(&mut self) -> &mut hyper::Request<Incoming> {
        &mut self.inner
    }

    pub async fn body_bytes(self) -> Result<bytes::Bytes, hyper::Error> {
        self.inner.into_body().collect().await.map(|body| body.to_bytes())
    }
}