diff --git a/src/core/Akka.Persistence.TestKit.Tests/JournalInterceptorsSpecs.cs b/src/core/Akka.Persistence.TestKit.Tests/JournalInterceptorsSpecs.cs
index f7638dad520..1d81c25da4d 100644
--- a/src/core/Akka.Persistence.TestKit.Tests/JournalInterceptorsSpecs.cs
+++ b/src/core/Akka.Persistence.TestKit.Tests/JournalInterceptorsSpecs.cs
@@ -73,7 +73,7 @@ public async Task cancelable_delay_must_call_next_interceptor_immediately_after_
 
             var startedAt = DateTime.Now;
             var task = delay.InterceptAsync(null);
-            await Task.Delay(delayDuration - epsilon);
+            await Task.Delay(delayDuration);
 
             probe.WasCalled.Should().BeFalse();
             cts.Cancel();
diff --git a/src/core/Akka.Persistence.TestKit.Tests/SnapshotStoreInterceptorsSpec.cs b/src/core/Akka.Persistence.TestKit.Tests/SnapshotStoreInterceptorsSpec.cs
index 50820959094..5f22ac6b7f2 100644
--- a/src/core/Akka.Persistence.TestKit.Tests/SnapshotStoreInterceptorsSpec.cs
+++ b/src/core/Akka.Persistence.TestKit.Tests/SnapshotStoreInterceptorsSpec.cs
@@ -63,7 +63,7 @@ public async Task cancelable_delay_must_call_next_interceptor_immediately_after_
 
             var startedAt = DateTime.Now;
             var task = delay.InterceptAsync(null, null);
-            await Task.Delay(delayDuration - epsilon);
+            await Task.Delay(delayDuration);
 
             probe.WasCalled.Should().BeFalse();
             cts.Cancel();