SaveAuthor.java

public Mono<Author> saveAuthor(Author author) {
		if (StringUtils.isNotBlank(author.getId())) {
			return authorRepository.findByIdAndDeleteIsFalse(author.getId())
			                       .switchIfEmpty(Mono.error(new Exception("No Author found with Id: " + author.getId())))
			                       .doOnSuccess(author1 -> {
				                       author1 = updateAuthor(author, author1);
				                       authorRepository.save(author1)
				                                       .subscribe();
			                       });
		}
		return authorRepository.save(author);
	}