.from(new JsonFilePublisher<ChatRoomTo>(chatroomsPath(), mapper, type))
.log()
.map(chatRoomTo -> new ChatRoom(
- chatRoomTo.getId(),
- chatRoomTo.getName(),
- chatRoomTo.getShard(),
- clock,
- factory.create(readMessages(chatRoomTo)),
- bufferSize));
+ chatRoomTo.getId(),
+ chatRoomTo.getName(),
+ clock,
+ factory.create(readMessages(chatRoomTo)),
+ bufferSize));
}
public void writeMessages(ChatRoomTo chatroomTo, Flux<Message> messageFlux)