+ .flatMapMany(chatRoomData -> chatRoomData.getMessages())
+ )
+ .then(Mono.just(chatRoomInfo))
+ .doOnSuccess(empty -> log.info("Stored {}", chatRoomInfo))
+ .doOnError(throwable -> log.error("Could not store {}: {}", chatRoomInfo, throwable))))
+ .doOnComplete(() -> log.info("Stored {}", chatHomeService))
+ .doOnError(throwable -> log.error("Could not store {}: {}", chatHomeService, throwable));