File tree Expand file tree Collapse file tree
GridDomain.Domain.Tests/Tools/Repositories Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11using System ;
22using System . Linq ;
3+ using GridDomain . Common ;
34using GridDomain . EventSourcing ;
45using GridDomain . Node ;
56using GridDomain . Tests . Framework . Configuration ;
@@ -39,15 +40,12 @@ public void Given_events_When_save_by_events_repository_Then_events_can_be_fetch
3940 new Message2 ( Guid . NewGuid ( ) ) { Id = 2 }
4041 } ;
4142
42- using ( var repo = CreateRepository ( ) )
43- {
44- var persistId = "testId" ;
45-
46- repo . Save ( persistId , events ) ;
43+ var persistId = "testId" ;
44+ var saveTime = BusinessDateTime . UtcNow ;
45+ CreateRepository ( ) . Save ( persistId , events ) ;
4746
48- var eventsLoaded = repo . Load ( persistId ) . Cast < Message > ( ) ;
49- CollectionAssert . AreEquivalent ( events . Cast < Message > ( ) . Select ( e => e . Id ) , eventsLoaded . Select ( e=> e . Id ) ) ;
50- }
47+ var eventsLoaded = CreateRepository ( ) . Load ( persistId ) . Where ( e => e . CreatedTime >= saveTime ) . Cast < Message > ( ) ;
48+ CollectionAssert . AreEquivalent ( events . Cast < Message > ( ) . Select ( e => e . Id ) , eventsLoaded . Select ( e=> e . Id ) ) ;
5149 }
5250
5351 protected virtual IRepository < DomainEvent > CreateRepository ( )
You can’t perform that action at this time.
0 commit comments