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

use crate::response::head::ResponseHead;
use futures::executor::block_on;
use futures::io::Cursor;
use http::{StatusCode, Version};

const INPUT: &[u8] = b"HTTP/1.1 201 Created\r\nconnection: close\r\n\r\n";

async fn check(output: &ResponseHead<'_>) {
    assert_eq!(output.version(), Version::HTTP_11);
    assert_eq!(output.status(), StatusCode::CREATED);
    assert_eq!(
        output.headers().get("Connection").unwrap().as_bytes(),
        b"close"
    );
}

#[test]
fn test() {
    block_on(async {
        let head = ResponseHead::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())
        );
    })
}