feat(imp):[#214] improve readability

eclipse-tractusx · Jan 18, 2024 · 0d2942e · 0d2942e
1 parent 641dd67
commit 0d2942e
Showing 1 changed file with 12 additions and 7 deletions.
diff --git a/...rg/eclipse/tractusx/irs/registryclient/decentral/DecentralDigitalTwinRegistryService.java b/...rg/eclipse/tractusx/irs/registryclient/decentral/DecentralDigitalTwinRegistryService.java
@@ -104,16 +104,21 @@ private List<AssetAdministrationShellDescriptor> fetchShellDescriptors(final Set
         final var connectorEndpoints = connectorEndpointsService.fetchConnectorEndpoints(bpn);
         calledEndpoints.addAll(connectorEndpoints);
 
-        final var service = endpointDataForConnectorsService;
+        return fetchShellDescriptorsForConnectorEndpoints(bpn, keys, connectorEndpoints);
+    }
+
+    private List<AssetAdministrationShellDescriptor> fetchShellDescriptorsForConnectorEndpoints(final String bpn,
+            final List<DigitalTwinRegistryKey> keys, final List<String> connectorEndpoints) {
 
         try {
 
-            final var futures = //
-                    service.findEndpointDataForConnectors(connectorEndpoints)
-                           .stream()
-                           .map(edrFuture -> edrFuture.thenCompose(
-                                   edr -> supplyAsync(() -> fetchShellDescriptorsForKey(keys, edr))))
-                           .toList();
+            final var futures = endpointDataForConnectorsService.findEndpointDataForConnectors(connectorEndpoints)
+                                                                .stream()
+                                                                .map(edrFuture -> edrFuture.thenCompose(
+                                                                        edr -> supplyAsync(
+                                                                                () -> fetchShellDescriptorsForKey(keys,
+                                                                                        edr))))
+                                                                .toList();
 
             return resultFinder.getFastestResult(futures).get();