WebFlux алгоритм работы с ошибками

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
import ru.suspitsyn.iotcloud.customer.common.ApiError;
import ru.suspitsyn.iotcloud.customer.service.CustomerService;
 
@Component
public class CustomerHandler {
 
    public static final String EMAIL_NEEDED = "Необходимо передать параметр: email";
    public static final String USER_WAS_NOT_CREATED = "Пользователь не был создан";
    @Autowired
    private CustomerService combinedUserService;
 
    /**
     * Request should have queryParam("email")
     */
    public Mono<ServerResponse> createUserByEmail(ServerRequest serverRequest)  {
 
 
        String email = serverRequest.queryParam("email").orElseThrow(
                RuntimeException::new
        );
 
        if (email.equals("")) {
            throw new RuntimeException();
        }
 
        return combinedUserService.createCustomerWithChecks(email)
                .flatMap(customer ->
                    ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                            .body(Mono.just(customer.getId().toString()), String.class)
                )
                //ВОПРОС ОПИСАННЫЙ В ПУНКТЕ 5. ЭТА ЧАСТЬ НЕ КОМПИЛИРУЕТСЯ
                .onErrorComplete(throwable -> ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                            .body(Mono.just(new ApiError(throwable.getMessage())), ApiError.class)
                );
 
 
    }
 
 
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;
import ru.suspitsyn.iotcloud.customer.entity.Customer;
import ru.suspitsyn.iotcloud.customer.entity.CustomerRepository;
 
import java.time.LocalDateTime;
import java.util.Optional;
 
@Service
public class CustomerServiceImpl implements CustomerService {
 
    public static final String USER_EXISTS_ERROR = "Пользователь с почтой %s уже существует";
    @Autowired
    CustomerRepository customerRepository;
 
    @Override
    public Optional<Customer> getCustomerById(Long id) {
        return Optional.empty();
    }
 
    @Override
    public Mono<Customer> getCustomerByEmail(String email) {
        return customerRepository.findByEmail(email);
    }
 
    @Override
    public Mono<Customer> createCustomerWithChecks(String email) {
        return this.getCustomerByEmail(email)
                .flatMap(customer -> {
                /////////// ВОПРОС № 1 Без этой конструкции не работает
                    if (true) {
                        throw new RuntimeException(String.format(USER_EXISTS_ERROR, email));
                    }
              /////////// А ВОТ ЭТА ШТУКА, В ПРИНЦИПЕ, НЕ НУЖНА, НО БЕЗ НЕЕ НЕ РАБОТАЕТ
                    return Mono.just(customer);
                })
 
                .switchIfEmpty(this.createCustomer(email));
 
    }
 
    @Override
    public Mono<Customer> createCustomer(String email) {
        Customer customer = new Customer();
        customer.setEmail(email);
        customer.setCreateDateTime(LocalDateTime.now());
        return customerRepository.save(customer);
    }
 
 
 
}

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
 
import java.time.LocalDateTime;
 
/**
 * Class to throw Custom Api Errors in Response Entity
 */
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
public class ApiError {
    private LocalDateTime timestamp;
    private String message;
    private String debugMessage;
 
    public ApiError(String message) {
        this.message = message;
        this.timestamp = LocalDateTime.now();
        this.debugMessage = null;
    }
 
    public ApiError(String message, Throwable error) {
        this.message = message;
        this.timestamp = LocalDateTime.now();
        this.debugMessage = error.getLocalizedMessage();
    }

public Mono<ServerResponse> createUserByEmail(ServerRequest serverRequest)  {
 
        //СТАРТ кривого куска
        Optional<String> email = serverRequest.queryParam("email");
        
        if (email.isEmpty() || email.get().equals("")) {
            return ServerResponse.badRequest()
                    .contentType(MediaType.APPLICATION_JSON)
                    .body(Mono.just(new ApiError(EMAIL_NEEDED)), ApiError.class);
        }
        //КОНЕЦ кривого куска
 
 
        return combinedUserService.createCustomerWithChecks(email.get())
                .flatMap(customer ->
                    ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                            .body(Mono.just(customer.getId().toString()), String.class)
                )
                .onErrorResume(throwable -> Mono.just(new ApiError(throwable.getMessage()))
                        .flatMap(s -> ServerResponse.badRequest()
                                .contentType(MediaType.APPLICATION_JSON)
                                .bodyValue(s)));
 
    }