astelm/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-08-12 09:40:25 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update d2c.rs

Browse Source
This commit is contained in:
Alexey
2026-06-29 11:37:30 +03:00
parent 3a5fe31262
commit 9a9fd3f55d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/proxy/middle_relay/d2c.rs
+4 -4
View File
@@ -55,8 +55,8 @@ pub(super) fn classify_me_d2c_flush_reason(
MeD2cFlushReason::QueueDrain MeD2cFlushReason::QueueDrain
} }
pub(super) fn me_d2c_flush_reason_requires_client_flush(reason: MeD2cFlushReason) -> bool { pub(super) fn me_d2c_flush_reason_requires_client_flush(_reason: MeD2cFlushReason) -> bool {
!matches!(reason, MeD2cFlushReason::QueueDrain) true
} }
#[cfg(test)] #[cfg(test)]
@@ -64,8 +64,8 @@ mod tests {
use super::*; use super::*;
#[test] #[test]
fn queue_drain_is_not_a_physical_flush_trigger() { fn all_flush_reasons_trigger_physical_flush() {
assert!(!me_d2c_flush_reason_requires_client_flush( assert!(me_d2c_flush_reason_requires_client_flush(
MeD2cFlushReason::QueueDrain MeD2cFlushReason::QueueDrain
)); ));
assert!(me_d2c_flush_reason_requires_client_flush( assert!(me_d2c_flush_reason_requires_client_flush(