h1: allow to override connection type in on-request handler

.github/workflows/linux.yml

@@ -8,7 +8,7 @@ jobs:
       fail-fast: false
       matrix:
         version:
-          - 1.51.0 # MSRV
+          - 1.53.0 # MSRV
           - stable
           - nightly
 
@@ -43,7 +43,7 @@ jobs:
           key: ${{ matrix.version }}-x86_64-unknown-linux-gnu-cargo-index-trimmed-${{ hashFiles('**/Cargo.lock') }}
 
       - name: Cache cargo tarpaulin
-        if: matrix.version == '1.51.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
+        if: matrix.version == '1.53.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
         uses: actions/cache@v1
         with:
           path: ~/.cargo/bin
@@ -57,19 +57,19 @@ jobs:
           args: --all --all-features --no-fail-fast -- --nocapture
 
       - name: Install tarpaulin
-        if: matrix.version == '1.51.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
+        if: matrix.version == '1.53.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
         continue-on-error: true
         run: |
           cargo install cargo-tarpaulin
 
       - name: Generate coverage report
-        if: matrix.version == '1.51.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
+        if: matrix.version == '1.53.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
         continue-on-error: true
         run: |
           cargo tarpaulin --out Xml --all --all-features
 
       - name: Upload to Codecov
-        if: matrix.version == '1.51.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
+        if: matrix.version == '1.53.0' && (github.ref == 'refs/heads/master' || github.event_name == 'pull_request')
         continue-on-error: true
         uses: codecov/codecov-action@v1
         with:

README.md

@@ -7,7 +7,7 @@
 [![codecov](https://codecov.io/gh/ntex-rs/ntex/branch/master/graph/badge.svg)](https://codecov.io/gh/ntex-rs/ntex) 
 [![crates.io](https://img.shields.io/crates/v/ntex.svg)](https://crates.io/crates/ntex) 
 [![Documentation](https://docs.rs/ntex/badge.svg)](https://docs.rs/ntex) 
-[![Version](https://img.shields.io/badge/rustc-1.51+-lightgray.svg)](https://blog.rust-lang.org/2021/03/25/Rust-1.51.0.html) 
+[![Version](https://img.shields.io/badge/rustc-1.53+-lightgray.svg)](https://blog.rust-lang.org/2021/06/17/Rust-1.53.0.html) 
 ![License](https://img.shields.io/crates/l/ntex.svg) 
 
   </p>
@@ -24,7 +24,7 @@
 ## Documentation & community resources
 
 * [Documentation](https://docs.rs/ntex)
-* Minimum supported Rust version: 1.48 or later
+* Minimum supported Rust version: 1.53 or later
 
 ## License
 

ntex/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.4.7] - 2021-11-02
+
+* h1: allow to override connection type in on-request handler
+
 ## [0.4.6] - 2021-10-29
 
 * time: fix wheel time calculations

ntex/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex"
-version = "0.4.6"
+version = "0.4.7"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Framework for composable network services"
 readme = "README.md"

ntex/README.md

@@ -7,7 +7,7 @@
 [![codecov](https://codecov.io/gh/ntex-rs/ntex/branch/master/graph/badge.svg)](https://codecov.io/gh/ntex-rs/ntex) 
 [![crates.io](https://img.shields.io/crates/v/ntex.svg)](https://crates.io/crates/ntex) 
 [![Documentation](https://docs.rs/ntex/badge.svg)](https://docs.rs/ntex) 
-[![Version](https://img.shields.io/badge/rustc-1.51+-lightgray.svg)](https://blog.rust-lang.org/2021/03/25/Rust-1.51.0.html) 
+[![Version](https://img.shields.io/badge/rustc-1.53+-lightgray.svg)](https://blog.rust-lang.org/2021/06/17/Rust-1.53.0.html) 
 ![License](https://img.shields.io/crates/l/ntex.svg) 
 
   </p>
@@ -24,7 +24,7 @@
 ## Documentation & community resources
 
 * [Documentation](https://docs.rs/ntex)
-* Minimum supported Rust version: 1.48 or later
+* Minimum supported Rust version: 1.53 or later
 
 ## License
 

ntex/src/http/h1/codec.rs

@@ -98,6 +98,10 @@ impl Codec {
         self.flags.get().contains(Flags::KEEPALIVE_ENABLED)
     }
 
+    pub(super) fn set_ctype(&self, ctype: ConnectionType) {
+        self.ctype.set(ctype)
+    }
+
     #[inline]
     #[doc(hidden)]
     pub fn set_date_header(&self, dst: &mut BytesMut) {

ntex/src/http/h1/dispatcher.rs

@@ -241,6 +241,9 @@ where
                             if let Poll::Ready(result) = Pin::new(fut).poll(cx) {
                                 match result {
                                     Ok(req) => {
+                                        this.inner
+                                            .codec
+                                            .set_ctype(req.head().connection_type());
                                         if req.head().expect() {
                                             // Handle normal requests with EXPECT: 100-Continue` header
                                             Some(CallState::Expect {