rust-h11 0.1.0

A pure-Rust, bring-your-own-I/O implementation of HTTP/1.1
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
33
34
35
36
37
38
39

use h11::{Connection, Data, EndOfMessage, Event, Headers, Response, Role};

fn main() -> Result<(), h11::ProtocolError> {
    let mut conn = Connection::new(Role::Server, None);
    conn.receive_data(
        b"POST /upload HTTP/1.1\r\n\
          Host: example.com\r\n\
          Expect: 100-continue\r\n\
          Content-Length: 5\r\n\r\n",
    )?;

    let Event::Request(request) = conn.next_event()? else {
        panic!("expected request head");
    };
    assert_eq!(request.target, b"/upload");
    assert!(conn.get_they_are_waiting_for_100_continue());

    let continue_response =
        Response::new_informational_http11(100, Headers::default(), "Continue")?;
    let continue_bytes = conn.send(continue_response.into())?.unwrap();
    assert!(continue_bytes.starts_with(b"HTTP/1.1 100 Continue\r\n"));
    assert!(!conn.get_they_are_waiting_for_100_continue());

    assert!(matches!(conn.next_event()?, Event::NeedData()));
    conn.receive_data(b"hello")?;

    let Event::Data(Data { data, .. }) = conn.next_event()? else {
        panic!("expected request body");
    };
    assert_eq!(data, b"hello");
    assert!(matches!(conn.next_event()?, Event::EndOfMessage(_)));

    let final_response =
        Response::new_final_http11(204, Headers::new([("Content-Length", "0")])?, "No Content")?;
    let response_bytes = conn.send(final_response.into())?.unwrap();
    assert!(response_bytes.starts_with(b"HTTP/1.1 204 No Content\r\n"));
    conn.send(EndOfMessage::default().into())?;
    Ok(())
}