+ }
+
+
+ Mono<Void> restore(StorageStrategy storageStrategy)
+ {
+ Flux<Message> messageFlux = storageStrategy.readChatRoomData(chatRoomId);
+
+ return messageFlux
+ .doOnNext(message -> messages.put(message.getKey(), message))
+ .count()
+ .doOnSuccess(count -> log.info("Restored InMemoryChatMessageService with {} messages", count))
+ .doOnError(throwable -> log.error("Could not restore InMemoryChatMessageService"))
+ .then();