@@ -133,7 +133,10 @@ public AspectModel load( final File file ) {
133
133
* @return the Aspect Model
134
134
*/
135
135
public AspectModel load ( final Collection <File > files ) {
136
- final List <AspectModelFile > migratedFiles = files .stream ().map ( AspectModelFileLoader ::load ).map ( this ::migrate ).toList ();
136
+ final List <AspectModelFile > migratedFiles = files .stream ()
137
+ .map ( AspectModelFileLoader ::load )
138
+ .map ( this ::migrate )
139
+ .toList ();
137
140
final LoaderContext loaderContext = new LoaderContext ();
138
141
resolve ( migratedFiles , loaderContext );
139
142
return buildAspectModel ( loaderContext .loadedFiles () );
@@ -287,8 +290,10 @@ private Set<String> getAllUrnsInModel( final Model model ) {
287
290
? Stream .of ( statement .getObject ().asResource ().getURI () )
288
291
: Stream .empty ();
289
292
290
- return Stream .of ( subjectUri , propertyUri , objectUri ).flatMap ( Function .identity () )
291
- .flatMap ( urn -> AspectModelUrn .from ( urn ).toJavaOptional ().stream () ).map ( AspectModelUrn ::toString );
293
+ return Stream .of ( subjectUri , propertyUri , objectUri )
294
+ .flatMap ( Function .identity () )
295
+ .flatMap ( urn -> AspectModelUrn .from ( urn ).toJavaOptional ().stream () )
296
+ .map ( AspectModelUrn ::toString );
292
297
} ) ).flatMap ( Function .identity () ).collect ( toSet () );
293
298
}
294
299
@@ -372,7 +377,7 @@ private void markModelFileAsLoaded( final AspectModelFile modelFile, final Loade
372
377
}
373
378
}
374
379
375
- private void resolve ( List <AspectModelFile > inputFiles , final LoaderContext context ) {
380
+ private void resolve ( final List <AspectModelFile > inputFiles , final LoaderContext context ) {
376
381
for ( final AspectModelFile aspectModelFile : inputFiles ) {
377
382
context .unresolvedFiles ().push ( aspectModelFile );
378
383
}
@@ -387,7 +392,8 @@ private void resolve( List<AspectModelFile> inputFiles, final LoaderContext cont
387
392
}
388
393
389
394
while ( !context .unresolvedUrns ().isEmpty () ) {
390
- applyResolutionStrategy ( context .unresolvedUrns ().pop () ).map ( this ::migrate )
395
+ applyResolutionStrategy ( context .unresolvedUrns ().pop () )
396
+ .map ( this ::migrate )
391
397
.ifPresent ( resolvedFile -> markModelFileAsLoaded ( resolvedFile , context ) );
392
398
}
393
399
}
@@ -407,9 +413,11 @@ private AspectModel buildAspectModel( final Collection<AspectModelFile> inputFil
407
413
final Model model = file .sourceModel ();
408
414
final ModelElementFactory modelElementFactory = new ModelElementFactory ( mergedModel , Map .of (), element -> aspectModelFile );
409
415
final List <ModelElement > fileElements = model .listStatements ( null , RDF .type , (RDFNode ) null ).toList ().stream ()
410
- .map ( Statement ::getSubject ).filter ( RDFNode ::isURIResource )
416
+ .map ( Statement ::getSubject )
417
+ .filter ( RDFNode ::isURIResource )
411
418
.map ( resource -> mergedModel .createResource ( resource .getURI () ) )
412
- .map ( resource -> modelElementFactory .create ( ModelElement .class , resource ) ).toList ();
419
+ .map ( resource -> modelElementFactory .create ( ModelElement .class , resource ) )
420
+ .toList ();
413
421
aspectModelFile .setElements ( fileElements );
414
422
elements .addAll ( fileElements );
415
423
}
0 commit comments