summaryrefslogtreecommitdiff
path: root/broadcast/src/batch.rs
diff options
context:
space:
mode:
Diffstat (limited to 'broadcast/src/batch.rs')
-rw-r--r--broadcast/src/batch.rs1
1 files changed, 1 insertions, 0 deletions
diff --git a/broadcast/src/batch.rs b/broadcast/src/batch.rs
index d69771d..42cc3b8 100644
--- a/broadcast/src/batch.rs
+++ b/broadcast/src/batch.rs
@@ -50,6 +50,7 @@ impl MessageBatch {
self.first_added
.elapsed()
.saturating_sub(self.max_message_delay)
+ .saturating_sub(Duration::from_millis(10))
}
pub fn broadcast(