stream-httparse 0.2.6

A fast streaming HTTP-Parser
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use criterion::{black_box, BenchmarkId, Criterion};

use crate::{generate_header_text, generate_headers};

pub fn parsing(c: &mut Criterion) {
    let mut group = c.benchmark_group("HTTP-Response-Parser");
    for header_count in [2, 4, 8, 16, 32usize].iter() {
        let mut content = "HTTP/1.1 200 OK\r\n".to_owned();
        content.push_str(&generate_header_text(*header_count));
        content.push_str("\r\n");

        let content_bytes = content.as_bytes();

        group.bench_function(BenchmarkId::from_parameter(header_count), |b| {
            let mut parser = stream_httparse::streaming_parser::RespParser::new_capacity(4096);
            b.iter(|| {
                parser.block_parse(black_box(content_bytes));
                parser.clear();
            })
        });
    }
}

pub fn parse_finish(c: &mut Criterion) {
    let mut group = c.benchmark_group("HTTP-Response-Finish");
    for header_count in [2, 4, 8, 16, 32usize].iter() {
        let mut content = "HTTP/1.1 200 OK\r\n".to_owned();
        content.push_str(&generate_header_text(*header_count));
        content.push_str("\r\n");

        let content_bytes = content.as_bytes();

        group.bench_function(BenchmarkId::from_parameter(header_count), |b| {
            let mut parser = stream_httparse::streaming_parser::RespParser::new_capacity(4096);
            parser.block_parse(black_box(content_bytes));
            b.iter(|| {
                parser.finish();
            })
        });
    }
}

pub fn serialize(c: &mut Criterion) {
    let mut group = c.benchmark_group("HTTP-Response-Serialize");
    for header_count in [2, 4, 8, 16, 32usize].iter() {
        let headers = generate_headers(*header_count);
        let resp = stream_httparse::Response::new(
            "HTTP/1.1",
            stream_httparse::StatusCode::OK,
            headers,
            "Random Response Body".as_bytes().to_vec(),
        );

        group.bench_function(BenchmarkId::from_parameter(header_count), |b| {
            b.iter(|| {
                resp.serialize();
            })
        });
    }
}