Fix WriteActor unit test

petabridge · Aug 27, 2024 · cee8948 · cee8948
1 parent 79bdfc3
commit cee8948
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs b/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs
@@ -190,9 +190,6 @@ await WithJournalWrite(behavior => behavior.SetInterceptorAsync(new RepeatJourna
             var probe = CreateTestProbe();
             writer.Tell(CreateEnvelopeFor(1, 1), probe);
             probe!.ExpectMsg<PersistenceWriterProtocol.PersistFailed>();
-                
-            await WatchAsync(writer);
-            await ExpectTerminatedAsync(writer);
         });
     }
 
@@ -267,9 +264,6 @@ await WithSnapshotSave(behavior => behavior.SetInterceptorAsync(new RepeatSnapsh
             var probe = CreateTestProbe();
             writer.Tell(new SelectedSnapshot(new SnapshotMetadata("a", 999), 6), probe);
             probe!.ExpectMsg<PersistenceWriterProtocol.SnapshotFailed>();
-            
-            await WatchAsync(writer);
-            await ExpectTerminatedAsync(writer);
         });
     }