channel-server 0.1.0

crate request/response topic-publish/subject by channels in multithreads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::ops::Deref;

use crate::{Body, ChannelError, FromRequest, Request};

pub struct Data<T>(pub T);

impl<T> Deref for Data<T> {
    type Target = T;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

impl<'a, T: Send + Sync + 'static> FromRequest<'a> for Data<&'a T> {
    fn from_request(req: &'a Request, _body: &mut Body) -> Result<Self, ChannelError> {
        Ok(Data(req.extensions().get::<T>().ok_or_else(|| {
            ChannelError::GetDataError(std::any::type_name::<T>().into())
        })?))
    }
}