From 9a9fd3f55d35060dcc9e2141ff54a82493175d27 Mon Sep 17 00:00:00 2001
From: Alexey <247128645+axkurcom@users.noreply.github.com>
Date: Mon, 29 Jun 2026 11:37:30 +0300
Subject: [PATCH] Update d2c.rs

---
 src/proxy/middle_relay/d2c.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/proxy/middle_relay/d2c.rs b/src/proxy/middle_relay/d2c.rs
index 7faa702..a1906fc 100644
--- a/src/proxy/middle_relay/d2c.rs
+++ b/src/proxy/middle_relay/d2c.rs
@@ -55,8 +55,8 @@ pub(super) fn classify_me_d2c_flush_reason(
     MeD2cFlushReason::QueueDrain
 }
 
-pub(super) fn me_d2c_flush_reason_requires_client_flush(reason: MeD2cFlushReason) -> bool {
-    !matches!(reason, MeD2cFlushReason::QueueDrain)
+pub(super) fn me_d2c_flush_reason_requires_client_flush(_reason: MeD2cFlushReason) -> bool {
+    true
 }
 
 #[cfg(test)]
@@ -64,8 +64,8 @@ mod tests {
     use super::*;
 
     #[test]
-    fn queue_drain_is_not_a_physical_flush_trigger() {
-        assert!(!me_d2c_flush_reason_requires_client_flush(
+    fn all_flush_reasons_trigger_physical_flush() {
+        assert!(me_d2c_flush_reason_requires_client_flush(
             MeD2cFlushReason::QueueDrain
         ));
         assert!(me_d2c_flush_reason_requires_client_flush(