xitca-web 0.8.0

an async web framework
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

use core::convert::Infallible;

pub use http_grpc_rs::{error::GrpcError, status::GrpcStatus};

use crate::{
    body::ResponseBody,
    context::WebContext,
    http::{WebResponse, const_header_value::GRPC, header::CONTENT_TYPE},
    service::Service,
};

use super::Error;

impl<'r, C, B> Service<WebContext<'r, C, B>> for GrpcError {
    type Response = WebResponse;
    type Error = Infallible;

    async fn call(&self, ctx: WebContext<'r, C, B>) -> Result<Self::Response, Self::Error> {
        // gRPC "Trailers-Only" response: status goes in the response headers
        // (the single HEADERS frame with END_STREAM set).
        let mut res = ctx.into_response(ResponseBody::empty());
        res.headers_mut().insert(CONTENT_TYPE, GRPC);
        res.headers_mut().extend(self.trailers());
        Ok(res)
    }
}

impl From<GrpcError> for Error {
    fn from(e: GrpcError) -> Self {
        Self::from_service(e)
    }
}