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

use tokio_service::Service;
use std::fmt;

#[derive(Clone)]
pub struct Log<S> {
    upstream: S,
}

impl<S> Log<S> {
    pub fn new(upstream: S) -> Log<S> {
        Log { upstream: upstream }
    }
}

impl<S> Service for Log<S>
    where S: Service,
          S::Request: fmt::Debug,
{
    type Request = S::Request;
    type Response = S::Response;
    type Error = S::Error;
    type Future = S::Future;

    fn call(&self, request: Self::Request) -> Self::Future {
        println!("[REQUEST] {:?}", request);
        self.upstream.call(request)
    }
}