.doOnSuccess(emittedChatRoomInfo -> log.info("Stored {}", chatRoomInfo))
.doOnError(throwable -> log.error("Could not store {}: {}", chatRoomInfo, throwable)))
)
.doOnSuccess(emittedChatRoomInfo -> log.info("Stored {}", chatRoomInfo))
.doOnError(throwable -> log.error("Could not store {}: {}", chatRoomInfo, throwable)))
)