From e2228322701104486bee0493a731d270675cbc32 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Wed, 4 Dec 2024 15:23:20 +0500
Subject: [PATCH] Check service readiness for every turn

---
 ntex-io/CHANGES.md        |  4 ++++
 ntex-io/Cargo.toml        |  2 +-
 ntex-io/src/dispatcher.rs | 12 +-----------
 3 files changed, 6 insertions(+), 12 deletions(-)

diff --git a/ntex-io/CHANGES.md b/ntex-io/CHANGES.md
index c391cb0a..29791179 100644
--- a/ntex-io/CHANGES.md
+++ b/ntex-io/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [2.9.1] - 2024-12-04
+
+* Check service readiness for every turn
+
 ## [2.9.0] - 2024-12-04
 
 * Use updated Service trait
diff --git a/ntex-io/Cargo.toml b/ntex-io/Cargo.toml
index 9e933195..2b369e62 100644
--- a/ntex-io/Cargo.toml
+++ b/ntex-io/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-io"
-version = "2.9.0"
+version = "2.9.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Utilities for encoding and decoding frames"
 keywords = ["network", "framework", "async", "futures"]
diff --git a/ntex-io/src/dispatcher.rs b/ntex-io/src/dispatcher.rs
index 90a798aa..7ef865fc 100644
--- a/ntex-io/src/dispatcher.rs
+++ b/ntex-io/src/dispatcher.rs
@@ -160,7 +160,6 @@ where
     service: PipelineBinding<S, DispatchItem<U>>,
     error: Cell<Option<DispatcherError<S::Error, <U as Encoder>::Error>>>,
     inflight: Cell<u32>,
-    ready: Cell<bool>,
 }
 
 #[derive(Copy, Clone, Debug)]
@@ -222,7 +221,6 @@ where
             codec,
             error: Cell::new(None),
             inflight: Cell::new(0),
-            ready: Cell::new(false),
             service: Pipeline::new(service.into_service()).bind(),
         });
 
@@ -343,7 +341,6 @@ where
                         PollService::Continue => continue,
                     };
 
-                    slf.shared.ready.set(false);
                     slf.call_service(cx, item);
                 }
                 // handle write back-pressure
@@ -473,16 +470,9 @@ where
     }
 
     fn poll_service(&mut self, cx: &mut Context<'_>) -> Poll<PollService<U>> {
-        if self.shared.ready.get() {
-            return Poll::Ready(self.check_error());
-        }
-
         // wait until service becomes ready
         match self.shared.service.poll_ready(cx) {
-            Poll::Ready(Ok(_)) => {
-                self.shared.ready.set(true);
-                Poll::Ready(self.check_error())
-            }
+            Poll::Ready(Ok(_)) => Poll::Ready(self.check_error()),
             // pause io read task
             Poll::Pending => {
                 log::trace!(