kyoto_protocol 0.1.0

Protocol module for kyoto
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use bytes::{ Bytes, BytesMut, BufMut };

pub struct ResponseEncoder {
    /* So far we don't have any member for response encoder. */
}

impl ResponseEncoder {
    pub fn generate_response(val: Bytes) -> crate::Result<Bytes> {
        /* Generate status code and header for the response. */
        let resp_str = 
            format!("HTTP/1.1 200\r\nContent-Length: {}\r\n\r\n", val.len());
        
        /* Now add the actual response body. */
        let resp_bin = resp_str.as_bytes();
        let mut response = BytesMut::with_capacity(resp_bin.len() + val.len() + 5);
        response.put(resp_str.as_bytes());
        response.put(val);
        Ok(response.freeze())
    }
}