@Slf4j
public class SimpleChatHome implements ChatHome
{
- private final int shard;
private final Map<UUID, ChatRoom> chatrooms;
+ public SimpleChatHome(Flux<ChatRoom> chatroomFlux)
+ {
+ this(chatroomFlux, null);
+ }
+
public SimpleChatHome(
- int shard,
+ Integer shard,
Flux<ChatRoom> chatroomFlux)
{
log.info("Created SimpleChatHome for shard {}", shard);
chatroomFlux
.filter(chatRoom ->
{
- if (shard > -1 && chatRoom.getShard() == shard)
+ if (shard == null && chatRoom.getShard() == shard)
{
return true;
}
})
.toStream()
.forEach(chatroom -> chatrooms.put(chatroom.getId(), chatroom));
- this.shard = shard;
}