mirror of
https://github.com/actix/actix-web.git
synced 2024-12-29 11:30:41 +00:00
90 lines
2.8 KiB
Rust
90 lines
2.8 KiB
Rust
#![allow(clippy::uninlined_format_args)]
|
|
|
|
use std::convert::Infallible;
|
|
|
|
use actix_http::{encoding::Encoder, ContentEncoding, Request, Response, StatusCode};
|
|
use actix_service::{fn_service, Service as _};
|
|
use criterion::{black_box, criterion_group, criterion_main, Criterion};
|
|
|
|
static BODY: &[u8] = include_bytes!("../Cargo.toml");
|
|
|
|
fn compression_responses(c: &mut Criterion) {
|
|
let mut group = c.benchmark_group("compression responses");
|
|
|
|
group.bench_function("identity", |b| {
|
|
let rt = actix_rt::Runtime::new().unwrap();
|
|
|
|
let identity_svc = fn_service(|_: Request| async move {
|
|
let mut res = Response::with_body(StatusCode::OK, ());
|
|
let body = black_box(Encoder::response(
|
|
ContentEncoding::Identity,
|
|
res.head_mut(),
|
|
BODY,
|
|
));
|
|
Ok::<_, Infallible>(black_box(res.set_body(black_box(body))))
|
|
});
|
|
|
|
b.iter(|| {
|
|
rt.block_on(identity_svc.call(Request::new())).unwrap();
|
|
});
|
|
});
|
|
|
|
group.bench_function("gzip", |b| {
|
|
let rt = actix_rt::Runtime::new().unwrap();
|
|
|
|
let identity_svc = fn_service(|_: Request| async move {
|
|
let mut res = Response::with_body(StatusCode::OK, ());
|
|
let body = black_box(Encoder::response(
|
|
ContentEncoding::Gzip,
|
|
res.head_mut(),
|
|
BODY,
|
|
));
|
|
Ok::<_, Infallible>(black_box(res.set_body(black_box(body))))
|
|
});
|
|
|
|
b.iter(|| {
|
|
rt.block_on(identity_svc.call(Request::new())).unwrap();
|
|
});
|
|
});
|
|
|
|
group.bench_function("br", |b| {
|
|
let rt = actix_rt::Runtime::new().unwrap();
|
|
|
|
let identity_svc = fn_service(|_: Request| async move {
|
|
let mut res = Response::with_body(StatusCode::OK, ());
|
|
let body = black_box(Encoder::response(
|
|
ContentEncoding::Brotli,
|
|
res.head_mut(),
|
|
BODY,
|
|
));
|
|
Ok::<_, Infallible>(black_box(res.set_body(black_box(body))))
|
|
});
|
|
|
|
b.iter(|| {
|
|
rt.block_on(identity_svc.call(Request::new())).unwrap();
|
|
});
|
|
});
|
|
|
|
group.bench_function("zstd", |b| {
|
|
let rt = actix_rt::Runtime::new().unwrap();
|
|
|
|
let identity_svc = fn_service(|_: Request| async move {
|
|
let mut res = Response::with_body(StatusCode::OK, ());
|
|
let body = black_box(Encoder::response(
|
|
ContentEncoding::Zstd,
|
|
res.head_mut(),
|
|
BODY,
|
|
));
|
|
Ok::<_, Infallible>(black_box(res.set_body(black_box(body))))
|
|
});
|
|
|
|
b.iter(|| {
|
|
rt.block_on(identity_svc.call(Request::new())).unwrap();
|
|
});
|
|
});
|
|
|
|
group.finish();
|
|
}
|
|
|
|
criterion_group!(benches, compression_responses);
|
|
criterion_main!(benches);
|