diff --git a/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/virtualthreads/ProductService.java b/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/virtualthreads/ProductService.java
index 5395770d7e..f174e4c6fe 100644
--- a/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/virtualthreads/ProductService.java
+++ b/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/virtualthreads/ProductService.java
@@ -26,7 +26,7 @@ class ProductService {
 
     private void computePriceAndPublishMessage(String productId, String cartId) {
         Product product = repository.findById(productId)
-            .orElseThrow(() -> new IllegalArgumentException("not found!"));
+          .orElseThrow(() -> new IllegalArgumentException("not found!"));
 
         Price price = computePrice(productId, product);
 
@@ -35,11 +35,9 @@ class ProductService {
     }
 
     private Price computePrice(String productId, Product product) {
-        if (product.category()
-            .isEligibleForDiscount()) {
+        if (product.category().isEligibleForDiscount()) {
             BigDecimal discount = discountService.discountForProduct(productId);
-            return product.basePrice()
-                .applyDiscount(discount);
+            return product.basePrice().applyDiscount(discount);
         }
         return product.basePrice();
     }
diff --git a/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/webflux/ProductService.java b/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/webflux/ProductService.java
index 0e950b501e..90519ec627 100644
--- a/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/webflux/ProductService.java
+++ b/spring-reactive-modules/spring-reactive-performance/src/main/java/com/baeldung/spring/reactive/performance/webflux/ProductService.java
@@ -22,17 +22,16 @@ class ProductService {
 
     public void addProductToCart(String productId, String cartId) {
         repository.findById(productId)
-            .switchIfEmpty(Mono.error(() -> new IllegalArgumentException("not found!")))
-            .flatMap(this::computePrice)
-            .map(price -> new ProductAddedToCartEvent(productId, price.value(), price.currency(), cartId))
-            .subscribe(event -> kafkaTemplate.send(PRODUCT_ADDED_TO_CART_TOPIC, cartId, event));
+          .switchIfEmpty(Mono.error(() -> new IllegalArgumentException("not found!")))
+          .flatMap(this::computePrice)
+          .map(price -> new ProductAddedToCartEvent(productId, price.value(), price.currency(), cartId))
+          .subscribe(event -> kafkaTemplate.send(PRODUCT_ADDED_TO_CART_TOPIC, cartId, event));
     }
 
     private Mono<Price> computePrice(Product product) {
-        if (product.category()
-            .isEligibleForDiscount()) {
+        if (product.category().isEligibleForDiscount()) {
             return discountService.discountForProduct(product.id())
-                .map(product.basePrice()::applyDiscount);
+              .map(product.basePrice()::applyDiscount);
         }
         return Mono.just(product.basePrice());
     }