private final LinkedHashMap<Message.MessageKey, Message> messages;
- public InMemoryChatRoomService(LinkedHashMap<Message.MessageKey, Message> messages)
- {
- this.messages = messages;
- }
-
public InMemoryChatRoomService(Flux<Message> messageFlux)
{
log.debug("Creating InMemoryChatRoomService");
}
@Override
- public Message persistMessage(
+ public Mono<Message> persistMessage(
Message.MessageKey key,
LocalDateTime timestamp,
String text)
{
Message message = new Message(key, (long)messages.size(), timestamp, text);
messages.put(message.getKey(), message);
- return message;
+ return Mono.just(message);
}
@Override