Skip to content

Commit

Permalink
Fixing comments
Browse files Browse the repository at this point in the history
  • Loading branch information
einari committed Jan 22, 2025
1 parent 8dac053 commit 7a59a3f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,13 +50,13 @@ async Task Because()
FailedPartitionsBeforeRetry = await EventStore.WaitForThereToBeFailedPartitions(ObserverId);
Jobs = await EventStore.WaitForThereToBeJobs(waitTime);

// Wait for the second event to have been handled
// Wait for the first event to be handled a second time (retry)
await Tcs[1].Task.WaitAsync(waitTime);

// Append an event to be caught up
await EventStore.EventLog.Append(EventSourceId, Event);

// Wait for the third event to have been handled
// Wait for the second event to have been handled for the third time after retry
await Tcs[2].Task.WaitAsync(waitTime);
JobsWithCatchUp = await EventStore.WaitForThereToBeJobs(waitTime);
JobsAfterCompleted = await EventStore.WaitForThereToBeNoJobs(waitTime);
Expand Down

0 comments on commit 7a59a3f

Please sign in to comment.