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