diff --git a/src/Proto.Actor/Deduplication/DeduplicationContext.cs b/src/Proto.Actor/Deduplication/DeduplicationContext.cs index a6b87a1e8f..071035dbc8 100644 --- a/src/Proto.Actor/Deduplication/DeduplicationContext.cs +++ b/src/Proto.Actor/Deduplication/DeduplicationContext.cs @@ -110,7 +110,7 @@ private void CleanIfNeeded(long cutoff, long now) _cleanedAt = now; _oldest = 0; } - else if (_processed.Count >= 50 && _cleanedAt < _oldest) + else if (_processed.Count >= 50 && _cleanedAt <= _oldest) { var oldest = long.MaxValue;