diff options
| author | Aria <me@aria.rip> | 2023-10-20 00:33:52 +0100 |
|---|---|---|
| committer | Aria <me@aria.rip> | 2023-10-20 00:33:52 +0100 |
| commit | 4b6e257263f7bb6eaebb9be672f88bda85c77586 (patch) | |
| tree | ba3e5130284a96e73418be1440a97646b1727bdf /broadcast/src/batch.rs | |
| parent | bb54fd5b450ea1b126f7c31845f12893bf061058 (diff) | |
broadcast batching with minimal set of messages needed
Diffstat (limited to 'broadcast/src/batch.rs')
| -rw-r--r-- | broadcast/src/batch.rs | 1 |
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( |