File tree Expand file tree Collapse file tree
src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/read/getalldwellings Expand file tree Collapse file tree Original file line number Diff line number Diff line change 55 <parent >
66 <groupId >org.springframework.boot</groupId >
77 <artifactId >spring-boot-starter-parent</artifactId >
8- <version >3.4.2 </version >
8+ <version >3.4.3 </version >
99 <relativePath /> <!-- lookup parent from repository -->
1010 </parent >
1111 <groupId >com.dddheroes</groupId >
3030 <axon .version>4.11.1</axon .version>
3131 <java .version>23</java .version>
3232 <spring-doc .version>2.8.5</spring-doc .version>
33- <spring-modulith .version>1.3.2 </spring-modulith .version>
33+ <spring-modulith .version>1.3.4 </spring-modulith .version>
3434 </properties >
3535 <dependencies >
3636 <dependency >
Original file line number Diff line number Diff line change 44import com .dddheroes .heroesofddd .creaturerecruitment .read .DwellingReadModelRepository ;
55import com .dddheroes .heroesofddd .creaturerecruitment .events .DwellingBuilt ;
66import com .dddheroes .heroesofddd .shared .application .GameMetaData ;
7- import com .google .common .collect .Streams ;
87import org .axonframework .config .ProcessingGroup ;
98import org .axonframework .eventhandling .EventHandler ;
109import org .axonframework .messaging .annotation .MetaDataValue ;
1110import org .axonframework .queryhandling .QueryHandler ;
1211import org .springframework .stereotype .Component ;
1312
1413import java .util .concurrent .ConcurrentLinkedDeque ;
14+ import java .util .stream .Stream ;
1515
1616@ ProcessingGroup ("Read_GetAllDwellings_QueryCache" )
1717@ Component
@@ -28,12 +28,12 @@ class GetAllDwellingsQueryHandler {
2828 GetAllDwellings .Result handle (GetAllDwellings query ) {
2929 var gameId = query .gameId ().raw ();
3030 var dwellings = dwellingReadModelRepository .findAllByGameId (gameId );
31- var result = Streams .concat (
32- dwellings .stream (),
33- cache .stream ().filter (it -> it .getGameId ().equals (gameId ))
34- ) // todo: check ordering
35- .distinct ()
36- .toList ();
31+ var result = Stream .concat (
32+ dwellings .stream (),
33+ cache .stream ().filter (it -> it .getGameId ().equals (gameId ))
34+ ) // todo: check ordering
35+ .distinct ()
36+ .toList ();
3737 return new GetAllDwellings .Result (result );
3838 }
3939
You can’t perform that action at this time.
0 commit comments