From 16508e373d40ed49d1d281b64a3b4b6b1c298482 Mon Sep 17 00:00:00 2001 From: Gregorius Soedharmo Date: Tue, 1 Oct 2024 21:16:27 +0700 Subject: [PATCH] Refactor additional method calls --- src/core/Akka.Persistence.TCK.Tests/LocalSnapshotStoreSpec.cs | 2 +- src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/core/Akka.Persistence.TCK.Tests/LocalSnapshotStoreSpec.cs b/src/core/Akka.Persistence.TCK.Tests/LocalSnapshotStoreSpec.cs index abb96739751..1f184ab6c62 100644 --- a/src/core/Akka.Persistence.TCK.Tests/LocalSnapshotStoreSpec.cs +++ b/src/core/Akka.Persistence.TCK.Tests/LocalSnapshotStoreSpec.cs @@ -42,7 +42,7 @@ protected override void AfterAll() public void LocalSnapshotStore_can_snapshot_actors_with_PersistenceId_containing_invalid_path_characters() { var pid = @"p\/:*?-1"; - SnapshotStore.Tell(new SaveSnapshot(new SnapshotMetadata(pid, 1, Sys.Scheduler.Now.DateTime), "sample data"), TestActor); + SnapshotStore.Tell(new SaveSnapshot(new SnapshotMetadata(pid, 1, Sys.Scheduler.DateTimeNow), "sample data"), TestActor); ExpectMsg(); SnapshotStore.Tell(new LoadSnapshot(pid, SnapshotSelectionCriteria.Latest, long.MaxValue), TestActor); diff --git a/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs b/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs index 43c69a42dff..c62c0f5e214 100644 --- a/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs +++ b/src/core/Akka.Persistence.TCK/Query/PersistenceIdsSpec.cs @@ -247,7 +247,8 @@ protected IActorRef WriteSnapshot(string persistenceId, int n) ExpectMsg($"{persistenceId}-{i}-done"); } - var metadata = new SnapshotMetadata(persistenceId, n + 10, Sys.Scheduler.Now.DateTime); + var metadata = new SnapshotMetadata(persistenceId, n + 10, Sys.Scheduler.DateTimeNow); + metadata.Timestamp.Kind.Should().Be(DateTimeKind.Utc); SnapshotStore.Tell(new SaveSnapshot(metadata, $"s-{n}"), _senderProbe.Ref); _senderProbe.ExpectMsg();