From 3baf497512e259d605c9d7666fb8ebd663f2bb67 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lo=C3=AFc=20Greffier?= <loic.greffier@hotmail.fr>
Date: Sat, 27 Jan 2024 20:08:52 +0100
Subject: [PATCH] sonar

---
 .../com/michelin/ns4kafka/services/SchemaService.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/michelin/ns4kafka/services/SchemaService.java b/src/main/java/com/michelin/ns4kafka/services/SchemaService.java
index fe744c11..046eee08 100644
--- a/src/main/java/com/michelin/ns4kafka/services/SchemaService.java
+++ b/src/main/java/com/michelin/ns4kafka/services/SchemaService.java
@@ -336,9 +336,9 @@ public List<SchemaReference> getReferences(Schema schema) {
      */
     public Mono<Boolean> existInOldVersions(Namespace namespace, Schema schema, List<Schema> oldSchemas) {
         return getSchemaReferences(schema, namespace)
-            .flatMap(schemaRefs -> {
+            .flatMap(schemaRefs ->
                 // If new schema matches any of the existing schemas, return unchanged
-                return Flux.fromIterable(oldSchemas)
+                Flux.fromIterable(oldSchemas)
                     .flatMap(oldSchema -> getSchemaReferences(oldSchema, namespace)
                         .map(oldSchemaRefs -> {
                             var currentSchema = new AvroSchema(oldSchema.getSpec().getSchema(),
@@ -351,7 +351,7 @@ public Mono<Boolean> existInOldVersions(Namespace namespace, Schema schema, List
                                 currentSchema.canonicalString())
                                 && Objects.equals(newSchema.references(), currentSchema.references());
                         }))
-                    .any(subjectComparison -> subjectComparison);
-            });
+                    .any(subjectComparison -> subjectComparison)
+            );
     }
 }