These changes shouldn't change the test intent, they should be safe. (#…

…6006)
akkadotnet · Jun 17, 2022 · 9db6ec2 · 9db6ec2
1 parent 5e1b066
commit 9db6ec2
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs b/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs
@@ -18,6 +18,7 @@
 using Akka.TestKit;
 using Akka.Util.Internal;
 using FluentAssertions;
+using FluentAssertions.Extensions;
 using Reactive.Streams;
 using Xunit;
 using Xunit.Abstractions;
@@ -86,15 +87,15 @@ public virtual void ReadJournal_AllPersistenceIds_should_find_new_events_after_d
             });
 
             Setup("j", 1);
-            probe.Within(TimeSpan.FromSeconds(10), () => probe.Request(5).ExpectNextUnordered(expected[0], expected[1]));
+            probe.Within(TimeSpan.FromSeconds(10), () => probe.Request(2).ExpectNextUnordered(expected[0], expected[1]));
 
             Setup("a1", 1);
             Thread.Sleep(TimeSpan.FromSeconds(2));
-            probe.ExpectNext(TimeSpan.FromSeconds(10));
+            probe.RequestNext(10.Seconds());
 
             Thread.Sleep(TimeSpan.FromSeconds(2));
             Setup("a2", 1);
-            probe.ExpectNext(TimeSpan.FromSeconds(10));
+            probe.RequestNext(10.Seconds());;
         }
 
         [Fact]