salt 0.0.4

Renamed to shio
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

use futures::{Future, IntoFuture};
use hyper::StatusCode;

use response::{BoxFutureResponse, Response};
use context::Context;

pub trait Handler: Send + Sync {
    type Result: IntoFuture<Item = Response>;

    fn call(&self, context: Context) -> Self::Result;

    fn boxed(self) -> BoxHandler
    where
        Self: Sized + 'static,
    {
        Box::new(move |ctx: Context| {
            Box::new(self.call(ctx).into_future().or_else(|_| {
                // FIXME: Do something with the error argument. Perhaps require at least `:Debug`
                //        so we can let someone know they hit the default error catcher

                Response::new().with_status(StatusCode::InternalServerError)
            })) as BoxFutureResponse
        })
    }
}

pub type BoxHandler = Box<Handler<Result = BoxFutureResponse>>;

impl<TError, TFuture, TFn> Handler for TFn
where
    TFuture: IntoFuture<Item = Response, Error = TError>,
    TFn: Send + Sync,
    TFn: Fn(Context) -> TFuture,
{
    type Result = TFuture;

    #[inline]
    fn call(&self, context: Context) -> Self::Result {
        (*self)(context)
    }
}