async-http-codec 0.8.0

async HTTP 1.1 encoding and decoding
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

use crate::request::head::RequestHead;
use futures::executor::block_on;
use futures::io::Cursor;
use http::{Method, Version};

const INPUT: &[u8] = b"GET / HTTP/1.1\r\nhost: www.example.com\r\nconnection: close\r\n\r\n";

async fn check(head: &RequestHead<'_>) {
    assert_eq!(head.version(), Version::HTTP_11);
    assert_eq!(head.method(), Method::GET);
    assert_eq!(head.uri(), "/");
    assert_eq!(
        head.headers.get("host").unwrap().as_bytes(),
        b"www.example.com"
    );
    assert_eq!(head.headers.get("connection").unwrap().as_bytes(), b"close");
}

#[test]
fn test() {
    block_on(async {
        let head = RequestHead::decode(Cursor::new(INPUT)).await.unwrap().1;
        check(&head).await;

        let mut transport = Cursor::new(Vec::new());
        head.encode(&mut transport).await.unwrap();
        assert_eq!(
            String::from_utf8(transport.into_inner()),
            String::from_utf8(INPUT.to_vec())
        );
    })
}