import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
+import java.time.Clock;
import static java.nio.file.StandardOpenOption.CREATE;
import static java.nio.file.StandardOpenOption.TRUNCATE_EXISTING;
private final Path storagePath;
+ private final Clock clock;
+ private final int bufferSize;
private final ObjectMapper mapper;
- private final InMemoryChatHomeService service;
@Override
.log()
.map(chatRoomTo ->
{
- InMemoryChatroomService chatroomService =
- new InMemoryChatroomService(readMessages(chatRoomTo));
- return service.restoreChatroom(
+ InMemoryChatRoomService chatroomService =
+ new InMemoryChatRoomService(readMessages(chatRoomTo));
+ return new ChatRoom(
chatRoomTo.getId(),
chatRoomTo.getName(),
- chatroomService);
+ clock,
+ chatroomService,
+ bufferSize);
});
}