fixing tests

Author: andrey.leskov

GridDomain.Domain.Tests/Sagas/InstanceSagas/Given_saga_When_publishing_several_start_messages.cs

@@ -26,17 +26,16 @@ public void When_publishing_start_message()
 
            secondStartMessage = new SleptWellEvent(Guid.NewGuid(), Guid.NewGuid(), SagaId);
 
-           waiter.Expect<SagaCreatedEvent<SoftwareProgrammingSagaData>>()
-                 .Create()
-                 .Publish(new GotTiredEvent(Guid.NewGuid(), Guid.NewGuid(), Guid.NewGuid(), SagaId),
-                          secondStartMessage)
-                 .Wait();
+            
+            var wait = waiter.Expect<SagaCreatedEvent<SoftwareProgrammingSagaData>>()
+                             .Create()
+                             .Publish(new GotTiredEvent(Guid.NewGuid(), Guid.NewGuid(), Guid.NewGuid(), SagaId));
 
-           LookupInstanceSagaActor<SoftwareProgrammingSaga, SoftwareProgrammingSagaData>(SagaId)
-                                                       .Tell(NotifyOnPersistenceEvents.Instance);
+            LookupInstanceSagaActor<SoftwareProgrammingSaga, SoftwareProgrammingSagaData>(SagaId)
+                                                        .Tell(NotifyOnPersistenceEvents.Instance);
 
-           int count = 2;
-           FishForMessage<Persisted>(m => ++count >=2);
+            Publisher.Publish(secondStartMessage);
+            FishForMessage<Persisted>(m => true );
 
            SagaData = LoadAggregate<SagaDataAggregate<SoftwareProgrammingSagaData>>(SagaId);
         }

GridDomain.Node/Actors/EventSourcedActor.cs

@@ -54,10 +54,9 @@ public EventSourcedActor(IConstructAggregates aggregateConstructor,
             {
                 var waiter = c.Waiter ?? Sender;
                 if (IsRecoveryFinished)
-                {
                     waiter.Tell(RecoveryCompleted.Instance);
-                }
-                else _persistenceWaiters.Add(waiter);
+
+                 _persistenceWaiters.Add(waiter);
             });
 
             Recover<DomainEvent>(e =>