Use NoOffset when running query from start (#7069)

akkadotnet · Jan 22, 2024 · ee77d7a · ee77d7a
1 parent 0cb2881
commit ee77d7a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/core/Akka.Persistence.TCK/Query/CurrentEventsByTagSpec.cs b/src/core/Akka.Persistence.TCK/Query/CurrentEventsByTagSpec.cs
@@ -212,7 +212,7 @@ public virtual void ReadJournal_query_CurrentEventsByTag_should_see_all_150_even
         }
 
         [Fact]
-        public void ReadJournal_query_CurrentEventsByTag_should_include_timestamp_in_EventEnvelope()
+        public virtual void ReadJournal_query_CurrentEventsByTag_should_include_timestamp_in_EventEnvelope()
         {
             if (ReadJournal is not ICurrentEventsByTagQuery queries)
                 throw IsTypeException.ForMismatchedType(nameof(ICurrentEventsByTagQuery), ReadJournal?.GetType().Name ?? "null");
@@ -226,7 +226,7 @@ public void ReadJournal_query_CurrentEventsByTag_should_include_timestamp_in_Eve
             a.Tell("a green banana");
             ExpectMsg("a green banana-done");
 
-            var greenSrc = queries.CurrentEventsByTag("green", offset: Sequence(0L));
+            var greenSrc = queries.CurrentEventsByTag("green", offset: NoOffset());
             var probe = greenSrc.RunWith(this.SinkProbe<EventEnvelope>(), Materializer);
             probe.Request(2);
             probe.ExpectNext().Timestamp.Should().BeGreaterThan(0);