sonar

michelin · Jan 27, 2024 · 3baf497 · 3baf497
1 parent 202df94
commit 3baf497
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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)
+            );
     }
 }