ntex-server 4.0.0-beta.1

Server for ntex 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
33
34
35
36
37
38
39

use std::marker::PhantomData;

use ntex_util::future::BoxFuture;

pub(crate) trait StateFactory<St> {
    fn clo(&self) -> Box<dyn StateFactory<St> + Send>;

    fn create(&self) -> BoxFuture<'static, Result<St, &'static str>>;
}

pub(crate) fn state_factory<F, St>(f: F) -> Box<dyn StateFactory<St> + Send>
where
    F: AsyncFn() -> Result<St, &'static str> + Send + Clone + 'static,
    St: 'static,
{
    Box::new(StateFactoryImpl { f, st: PhantomData })
}

struct StateFactoryImpl<F, St> {
    f: F,
    st: PhantomData<St>,
}

unsafe impl<F, St> Send for StateFactoryImpl<F, St> where F: Send {}

impl<F, St> StateFactory<St> for StateFactoryImpl<F, St>
where
    F: AsyncFn() -> Result<St, &'static str> + Send + Clone + 'static,
    St: 'static,
{
    fn clo(&self) -> Box<dyn StateFactory<St> + Send> {
        state_factory(self.f.clone())
    }

    fn create(&self) -> BoxFuture<'static, Result<St, &'static str>> {
        let f = self.f.clone();
        Box::pin(async move { (f)().await })
    }
}