diff --git a/src/main/java/org/warp/filesponge/FileSponge.java b/src/main/java/org/warp/filesponge/FileSponge.java index 086d760..2665dfb 100644 --- a/src/main/java/org/warp/filesponge/FileSponge.java +++ b/src/main/java/org/warp/filesponge/FileSponge.java @@ -61,7 +61,7 @@ public class FileSponge implements URLsHandler { return Mono .fromRunnable(() -> { synchronized (structuresLock) { - var cacheAccessClone = cacheAccess.clone(); + var cacheAccessClone = this.cacheAccess.clone(); cacheAccessClone.add(urlsCache); this.cacheAccess = cacheAccessClone; @@ -78,8 +78,9 @@ public class FileSponge implements URLsHandler { AtomicBoolean alreadyPrintedDebug = new AtomicBoolean(false); return Mono .fromCallable(() -> { - List> contentRequests = new ArrayList<>(cacheAccess.size()); - for (URLsDiskHandler urlsHandler : cacheAccess) { + var ca = this.cacheAccess; + List> contentRequests = new ArrayList<>(ca.size()); + for (URLsDiskHandler urlsHandler : ca) { contentRequests.add(urlsHandler.requestContent(url)); } return contentRequests; @@ -93,13 +94,15 @@ public class FileSponge implements URLsHandler { .switchIfEmpty(Mono .fromCallable(() -> { logger.debug("Downloading file \"{}\" content", url); - List> contentRequestsAndCaching = new ArrayList<>(urlsHandlers.size()); - for (URLsHandler urlsHandler : urlsHandlers) { + var uh = this.urlsHandlers; + List> contentRequestsAndCaching = new ArrayList<>(uh.size()); + for (URLsHandler urlsHandler : uh) { contentRequestsAndCaching.add(urlsHandler .requestContent(url) .flatMapSequential(dataBlock -> { - List> cacheWriteActions = new ArrayList<>(cacheWrite.size()); - for (URLsWriter urlsWriter : cacheWrite) { + var cw = this.cacheWrite; + List> cacheWriteActions = new ArrayList<>(cw.size()); + for (URLsWriter urlsWriter : cw) { cacheWriteActions.add(urlsWriter.writeContentBlock(url, dataBlock)); } return Mono.when(cacheWriteActions).thenReturn(dataBlock); @@ -120,8 +123,9 @@ public class FileSponge implements URLsHandler { public Mono requestMetadata(URL url) { return Mono .fromCallable(() -> { - List> metadataRequests = new ArrayList<>(cacheAccess.size()); - for (URLsDiskHandler urlsHandler : cacheAccess) { + var ca = this.cacheAccess; + List> metadataRequests = new ArrayList<>(ca.size()); + for (URLsDiskHandler urlsHandler : ca) { metadataRequests.add(urlsHandler.requestMetadata(url)); } return metadataRequests; @@ -135,13 +139,15 @@ public class FileSponge implements URLsHandler { .switchIfEmpty(Mono .fromCallable(() -> { logger.debug("Downloading file \"{}\" metadata", url); - List> metadataRequestsAndCaching = new ArrayList<>(urlsHandlers.size()); - for (URLsHandler urlsHandler : urlsHandlers) { + var uh = this.urlsHandlers; + List> metadataRequestsAndCaching = new ArrayList<>(uh.size()); + for (URLsHandler urlsHandler : uh) { metadataRequestsAndCaching.add(urlsHandler .requestMetadata(url) .flatMap(meta -> { - List> cacheWriteActions = new ArrayList<>(cacheWrite.size()); - for (URLsWriter urlsWriter : cacheWrite) { + var cw = this.cacheWrite; + List> cacheWriteActions = new ArrayList<>(cw.size()); + for (URLsWriter urlsWriter : cw) { cacheWriteActions.add(urlsWriter.writeMetadata(url, meta)); } return Mono.when(cacheWriteActions).thenReturn(meta);