Get coords from Google and use them to create address entity and then save a new user

Geolocalization.java

 Mono<GeocodingResponseDto> personalAddressGeo = bundle.getGeocodingClient().getGeocoding(URLEncoder.encode(requestDTO.getPersonalAddress().getFirstLine(), StandardCharsets.UTF_8.toString()), apiKey);
 Mono<GeocodingResponseDto> companyAddressGeo = bundle.getGeocodingClient().getGeocoding(URLEncoder.encode(requestDTO.getCompanyAddress().getFirstLine(), StandardCharsets.UTF_8.toString()), apiKey);

return personalAddressGeo
                .subscribeOn(Schedulers.immediate())
                .flatMap(this::handleNotFound)
                .doOnNext(x -> {
                    requestDTO.getPersonalAddress().setLat(x.getLocation().getLat());
                    requestDTO.getPersonalAddress().setLon(x.getLocation().getLon());
                })
                .then(companyAddressGeo)
                .flatMap(this::handleNotFound)
                .doOnNext(x -> {
                    requestDTO.getCompanyAddress().setLat(x.getLocation().getLat());
                    requestDTO.getCompanyAddress().setLon(x.getLocation().getLon());
                })
                .doOnNext(x -> {
                    UserInfoEntity user = bundle.getMapper().mapToUserInfoEntity(requestDTO);
                    bundle.getRepository().save(user);
                })
                .flatMap(x -> getByUsername(requestDTO.getUsername(), false))
                .map(UserDTO::getUsername)
                .map(this::getUrl);
    }

    private Mono<? extends Geometry> handleNotFound(GeocodingResponseDto x) {
        try {
            return Mono.just(x.getResults().get(0).getGeometry());
        } catch (Exception ex) {
            return Mono.error(new NotFoundException("Invalid address"));
        }
    }