Skip to content

Commit 7e50b5d

Browse files
MrGunflameseanmonstar
authored andcommitted
feat(client,server): remove tcp feature and code
1 parent d4b5bd4 commit 7e50b5d

40 files changed

+1649
-2760
lines changed

Cargo.toml

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -94,12 +94,6 @@ server = []
9494

9595
# Tokio support
9696
runtime = [
97-
"tcp",
98-
"tokio/rt",
99-
"tokio/time",
100-
]
101-
tcp = [
102-
"socket2",
10397
"tokio/net",
10498
"tokio/rt",
10599
"tokio/time",

benches/connect.rs

Lines changed: 32 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -3,35 +3,38 @@
33

44
extern crate test;
55

6-
use http::Uri;
7-
use hyper::client::connect::HttpConnector;
8-
use hyper::service::Service;
9-
use std::net::SocketAddr;
10-
use tokio::net::TcpListener;
6+
// TODO: Reimplement http_connector bench using hyper::client::conn
7+
// (instead of removed HttpConnector).
118

12-
#[bench]
13-
fn http_connector(b: &mut test::Bencher) {
14-
let _ = pretty_env_logger::try_init();
15-
let rt = tokio::runtime::Builder::new_current_thread()
16-
.enable_all()
17-
.build()
18-
.expect("rt build");
19-
let listener = rt
20-
.block_on(TcpListener::bind(&SocketAddr::from(([127, 0, 0, 1], 0))))
21-
.expect("bind");
22-
let addr = listener.local_addr().expect("local_addr");
23-
let dst: Uri = format!("http://{}/", addr).parse().expect("uri parse");
24-
let mut connector = HttpConnector::new();
9+
// use http::Uri;
10+
// use hyper::client::connect::HttpConnector;
11+
// use hyper::service::Service;
12+
// use std::net::SocketAddr;
13+
// use tokio::net::TcpListener;
2514

26-
rt.spawn(async move {
27-
loop {
28-
let _ = listener.accept().await;
29-
}
30-
});
15+
// #[bench]
16+
// fn http_connector(b: &mut test::Bencher) {
17+
// let _ = pretty_env_logger::try_init();
18+
// let rt = tokio::runtime::Builder::new_current_thread()
19+
// .enable_all()
20+
// .build()
21+
// .expect("rt build");
22+
// let listener = rt
23+
// .block_on(TcpListener::bind(&SocketAddr::from(([127, 0, 0, 1], 0))))
24+
// .expect("bind");
25+
// let addr = listener.local_addr().expect("local_addr");
26+
// let dst: Uri = format!("http://{}/", addr).parse().expect("uri parse");
27+
// let mut connector = HttpConnector::new();
3128

32-
b.iter(|| {
33-
rt.block_on(async {
34-
connector.call(dst.clone()).await.expect("connect");
35-
});
36-
});
37-
}
29+
// rt.spawn(async move {
30+
// loop {
31+
// let _ = listener.accept().await;
32+
// }
33+
// });
34+
35+
// b.iter(|| {
36+
// rt.block_on(async {
37+
// connector.call(dst.clone()).await.expect("connect");
38+
// });
39+
// });
40+
// }

0 commit comments

Comments
 (0)