We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0f46eaa commit b171e68Copy full SHA for b171e68
src/lib.rs
@@ -156,11 +156,12 @@ fn handle_stream_activity(
156
"Activity detected"
157
);
158
let new_deadline = calculate_new_deadline(timeouts.absolute_deadline, timeouts.activity);
159
- if new_deadline != *current_deadline {
+
160
+ if *current_deadline < timeouts.absolute_deadline && new_deadline != *current_deadline {
161
debug!(old = ?*current_deadline, new = ?new_deadline, "Updating deadline");
162
*current_deadline = new_deadline;
163
} else {
- debug!(deadline = ?*current_deadline, "Deadline remains unchanged (likely at absolute limit)");
164
+ debug!(deadline = ?*current_deadline, "Deadline remains unchanged (likely at absolute limit or no change)");
165
}
166
167
0 commit comments