From 375eadeb46368643cb6ca0c5edf98d2d626a270d Mon Sep 17 00:00:00 2001
From: fakeshadow <24548779@qq.com>
Date: Sun, 7 Mar 2021 14:47:53 +0800
Subject: [PATCH] add test

---
 actix-http/src/client/h1proto.rs |  2 +-
 actix-http/tests/test_client.rs  | 36 +++++++++++++++++++++++++++++++-
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/actix-http/src/client/h1proto.rs b/actix-http/src/client/h1proto.rs
index 961faf25e..0f9215520 100644
--- a/actix-http/src/client/h1proto.rs
+++ b/actix-http/src/client/h1proto.rs
@@ -114,7 +114,7 @@ where
             Ok((head, Payload::None))
         }
         _ => {
-            let pl: PayloadStream = PlStream::new(framed).boxed_local();
+            let pl: PayloadStream = Box::pin(PlStream::new(framed));
             Ok((head, pl.into()))
         }
     }
diff --git a/actix-http/tests/test_client.rs b/actix-http/tests/test_client.rs
index 91b2412f4..38fd03814 100644
--- a/actix-http/tests/test_client.rs
+++ b/actix-http/tests/test_client.rs
@@ -1,4 +1,6 @@
-use actix_http::{http, HttpService, Request, Response};
+use actix_http::{
+    error, http, http::StatusCode, HttpMessage, HttpService, Request, Response,
+};
 use actix_http_test::test_server;
 use actix_service::ServiceFactoryExt;
 use bytes::Bytes;
@@ -88,3 +90,35 @@ async fn test_with_query_parameter() {
     let response = request.send().await.unwrap();
     assert!(response.status().is_success());
 }
+
+#[actix_rt::test]
+async fn test_h1_expect() {
+    let srv = test_server(move || {
+        HttpService::build()
+            .expect(|req: Request| async {
+                if req.headers().contains_key("AUTH") {
+                    Ok(req)
+                } else {
+                    Err(error::ErrorBadRequest("bad request"))
+                }
+            })
+            .h1(|_| async { Ok::<_, ()>(Response::Ok().finish()) })
+            .tcp()
+    })
+    .await;
+
+    let request = srv
+        .request(http::Method::GET, srv.url("/"))
+        .insert_header(("Expect", "100-continue"));
+
+    let response = request.send().await.unwrap();
+    assert_eq!(response.status(), StatusCode::BAD_REQUEST);
+
+    let request = srv
+        .request(http::Method::GET, srv.url("/"))
+        .insert_header(("Expect", "100-continue"))
+        .insert_header(("AUTH", "996"));
+
+    let response = request.send().await.unwrap();
+    assert!(response.status().is_success());
+}