swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
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
42
43
44
45
46

use std::sync::Arc;

use futures::Async;
use tk_http::server::{Error, Codec, RecvMode};
use tk_http::server as http;

use config::Config;
use incoming::{Request, Reply, Encoder, IntoContext, Debug};


pub struct QuickReply<F> {
    inner: Option<(F, Arc<Config>, Debug)>,
}


pub fn reply<F, C, S: 'static>(ctx: C, f: F)
    -> Request<S>
    where F: FnOnce(Encoder<S>) -> Reply<S> + 'static,
          C: IntoContext,
{
    let (cfg, debug) = ctx.into_context();
    Box::new(QuickReply {
        inner: Some((f, cfg, debug)),
    })
}

impl<F, S> Codec<S> for QuickReply<F>
    where F: FnOnce(Encoder<S>) -> Reply<S>,
{
    type ResponseFuture = Reply<S>;
    fn recv_mode(&mut self) -> RecvMode {
        RecvMode::buffered_upfront(0)
    }
    fn data_received(&mut self, data: &[u8], end: bool)
        -> Result<Async<usize>, Error>
    {
        assert!(end);
        assert!(data.len() == 0);
        Ok(Async::Ready(0))
    }
    fn start_response(&mut self, e: http::Encoder<S>) -> Reply<S> {
        let (func, config, debug) = self.inner.take()
            .expect("start response called once");
        func(Encoder::new(e, (config, debug)))
    }
}