attempting to debug Akka.Persistence.TestKit.Tests

Aaronontheweb · Jan 4, 2024 · df57633 · df57633
1 parent 85f9d99
commit df57633
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 5 deletions.
diff --git a/src/core/Akka.Persistence.TestKit.Tests/Bug4762FixSpec.cs b/src/core/Akka.Persistence.TestKit.Tests/Bug4762FixSpec.cs
@@ -13,6 +13,7 @@
 using Akka.Actor;
 using Akka.Event;
 using Xunit;
+using Xunit.Abstractions;
 
 namespace Akka.Persistence.TestKit.Tests
 {
@@ -21,6 +22,11 @@ namespace Akka.Persistence.TestKit.Tests
     /// </summary>
     public class Bug4762FixSpec : PersistenceTestKit
     {
+        public Bug4762FixSpec(ITestOutputHelper outputHelper) : base(output: outputHelper)
+        {
+
+        }
+
         private class WriteMessage
         { }
 
@@ -65,10 +71,10 @@ protected override void OnRecover(object message)
         }
 
         [Fact]
-        public async Task TestJournal_PersistAll_should_only_count_each_event_exceptions_once()
+        public Task TestJournal_PersistAll_should_only_count_each_event_exceptions_once()
         {
             var probe = CreateTestProbe();
-            await WithJournalWrite(write => write.Pass(), async () =>
+            return WithJournalWrite(write => write.Pass(), async () =>
             {
                 var actor = ActorOf(() => new TestActor2(probe));
                 Watch(actor);

diff --git a/src/core/Akka.Persistence.TestKit/Journal/JournalRecoveryBehavior.cs b/src/core/Akka.Persistence.TestKit/Journal/JournalRecoveryBehavior.cs
@@ -17,7 +17,7 @@ public class JournalRecoveryBehavior
     {
         internal JournalRecoveryBehavior(IJournalBehaviorSetter setter)
         {
-            this.Setter = setter;
+            Setter = setter;
         }
 
         private IJournalBehaviorSetter Setter { get; }

diff --git a/src/core/Akka.Persistence.TestKit/Journal/JournalRecoveryBehaviorSetter.cs b/src/core/Akka.Persistence.TestKit/Journal/JournalRecoveryBehaviorSetter.cs
@@ -18,7 +18,7 @@ internal class JournalRecoveryBehaviorSetter : IJournalBehaviorSetter
     {
         internal JournalRecoveryBehaviorSetter(IActorRef journal)
         {
-            this._journal = journal;
+            _journal = journal;
         }
 
         private readonly IActorRef _journal;

diff --git a/src/core/Akka.Persistence.TestKit/Journal/JournalWriteBehaviorSetter.cs b/src/core/Akka.Persistence.TestKit/Journal/JournalWriteBehaviorSetter.cs
@@ -18,7 +18,7 @@ internal class JournalWriteBehaviorSetter : IJournalBehaviorSetter
     {
         internal JournalWriteBehaviorSetter(IActorRef journal)
         {
-            this._journal = journal;
+            _journal = journal;
         }
 
         private readonly IActorRef _journal;