@@ -2270,61 +2270,61 @@ mod conn {
2270
2270
// future::join(server, client).await;
2271
2271
// }
2272
2272
2273
- #[ tokio:: test]
2274
- async fn get_custom_reason_phrase ( ) {
2275
- let _ = :: pretty_env_logger:: try_init ( ) ;
2276
- let listener = TkTcpListener :: bind ( SocketAddr :: from ( ( [ 127 , 0 , 0 , 1 ] , 0 ) ) )
2277
- . await
2278
- . unwrap ( ) ;
2279
- let addr = listener. local_addr ( ) . unwrap ( ) ;
2273
+ // #[tokio::test]
2274
+ // async fn get_custom_reason_phrase() {
2275
+ // let _ = ::pretty_env_logger::try_init();
2276
+ // let listener = TkTcpListener::bind(SocketAddr::from(([127, 0, 0, 1], 0)))
2277
+ // .await
2278
+ // .unwrap();
2279
+ // let addr = listener.local_addr().unwrap();
2280
2280
2281
- let server = async move {
2282
- let mut sock = listener. accept ( ) . await . unwrap ( ) . 0 ;
2283
- let mut buf = [ 0 ; 4096 ] ;
2284
- let n = sock. read ( & mut buf) . await . expect ( "read 1" ) ;
2281
+ // let server = async move {
2282
+ // let mut sock = listener.accept().await.unwrap().0;
2283
+ // let mut buf = [0; 4096];
2284
+ // let n = sock.read(&mut buf).await.expect("read 1");
2285
2285
2286
- // Notably:
2287
- // - Just a path, since just a path was set
2288
- // - No host, since no host was set
2289
- let expected = "GET /a HTTP/1.1\r \n \r \n " ;
2290
- assert_eq ! ( s( & buf[ ..n] ) , expected) ;
2286
+ // // Notably:
2287
+ // // - Just a path, since just a path was set
2288
+ // // - No host, since no host was set
2289
+ // let expected = "GET /a HTTP/1.1\r\n\r\n";
2290
+ // assert_eq!(s(&buf[..n]), expected);
2291
2291
2292
- sock. write_all ( b"HTTP/1.1 200 Alright\r \n Content-Length: 0\r \n \r \n " )
2293
- . await
2294
- . unwrap ( ) ;
2295
- } ;
2292
+ // sock.write_all(b"HTTP/1.1 200 Alright\r\nContent-Length: 0\r\n\r\n")
2293
+ // .await
2294
+ // .unwrap();
2295
+ // };
2296
2296
2297
- let client = async move {
2298
- let tcp = tcp_connect ( & addr) . await . expect ( "connect" ) ;
2299
- let ( mut client, conn) = conn:: handshake ( tcp) . await . expect ( "handshake" ) ;
2297
+ // let client = async move {
2298
+ // let tcp = tcp_connect(&addr).await.expect("connect");
2299
+ // let (mut client, conn) = conn::handshake(tcp).await.expect("handshake");
2300
2300
2301
- tokio:: task:: spawn ( async move {
2302
- conn. await . expect ( "http conn" ) ;
2303
- } ) ;
2301
+ // tokio::task::spawn(async move {
2302
+ // conn.await.expect("http conn");
2303
+ // });
2304
2304
2305
- let req = Request :: builder ( )
2306
- . uri ( "/a" )
2307
- . body ( Default :: default ( ) )
2308
- . unwrap ( ) ;
2309
- let mut res = client. send_request ( req) . await . expect ( "send_request" ) ;
2310
- assert_eq ! ( res. status( ) , hyper:: StatusCode :: OK ) ;
2311
- assert_eq ! (
2312
- res. extensions( )
2313
- . get:: <hyper:: ext:: ReasonPhrase >( )
2314
- . expect( "custom reason phrase is present" )
2315
- . as_bytes( ) ,
2316
- & b"Alright" [ ..]
2317
- ) ;
2318
- assert_eq ! ( res. headers( ) . len( ) , 1 ) ;
2319
- assert_eq ! (
2320
- res. headers( ) . get( http:: header:: CONTENT_LENGTH ) . unwrap( ) ,
2321
- "0"
2322
- ) ;
2323
- assert ! ( res. body_mut( ) . next( ) . await . is_none( ) ) ;
2324
- } ;
2305
+ // let req = Request::builder()
2306
+ // .uri("/a")
2307
+ // .body(Default::default())
2308
+ // .unwrap();
2309
+ // let mut res = client.send_request(req).await.expect("send_request");
2310
+ // assert_eq!(res.status(), hyper::StatusCode::OK);
2311
+ // assert_eq!(
2312
+ // res.extensions()
2313
+ // .get::<hyper::ext::ReasonPhrase>()
2314
+ // .expect("custom reason phrase is present")
2315
+ // .as_bytes(),
2316
+ // &b"Alright"[..]
2317
+ // );
2318
+ // assert_eq!(res.headers().len(), 1);
2319
+ // assert_eq!(
2320
+ // res.headers().get(http::header::CONTENT_LENGTH).unwrap(),
2321
+ // "0"
2322
+ // );
2323
+ // assert!(res.body_mut().next().await.is_none());
2324
+ // };
2325
2325
2326
- future:: join ( server, client) . await ;
2327
- }
2326
+ // future::join(server, client).await;
2327
+ // }
2328
2328
2329
2329
#[ test]
2330
2330
fn incoming_content_length ( ) {
0 commit comments