: throwable);
}
- public Flux<ChatRoomData> getChatRoomData()
- {
- return Flux
- .fromIterable(ownedShards)
- .flatMap(shard -> chatHomes[shard].getChatRoomData());
- }
-
-
-
private int selectShard(UUID chatroomId)
{
return shardingStrategy.selectShard(chatroomId);