{
JavaType type = mapper.getTypeFactory().constructType(ChatRoomTo.class);
return Flux
.from(new JsonFilePublisher<ChatRoomTo>(chatroomsPath(), mapper, type))
.log()
.map(chatRoomTo -> new ChatRoom(
{
JavaType type = mapper.getTypeFactory().constructType(ChatRoomTo.class);
return Flux
.from(new JsonFilePublisher<ChatRoomTo>(chatroomsPath(), mapper, type))
.log()
.map(chatRoomTo -> new ChatRoom(