diff --git a/pom.xml b/pom.xml index 4f59f7e..f83f34d 100644 --- a/pom.xml +++ b/pom.xml @@ -105,12 +105,12 @@ io.projectreactor reactor-core - 3.4.13 + 3.4.18 io.projectreactor reactor-test - 3.4.13 + 3.4.18 test diff --git a/src/main/java/org/warp/filesponge/DiskCache.java b/src/main/java/org/warp/filesponge/DiskCache.java index e9b08f1..cf6ef4b 100644 --- a/src/main/java/org/warp/filesponge/DiskCache.java +++ b/src/main/java/org/warp/filesponge/DiskCache.java @@ -216,8 +216,8 @@ public class DiskCache implements URLsDiskHandler, URLsWriter { var blockKeyMono = Mono.fromCallable(() -> getBlockKey(url, blockId)); return fileContent .get(null, blockKeyMono) - .map(dataToReceive -> { - try (var data = dataToReceive) { + .map(data -> { + try (data) { int blockOffset = getBlockOffset(blockId); int blockLength = data.readableBytes(); if (meta.size() != -1) { @@ -254,8 +254,8 @@ public class DiskCache implements URLsDiskHandler, URLsWriter { Mono urlKeyMono = Mono.fromCallable(() -> serializeUrl(url)); return fileMetadata .get(null, urlKeyMono) - .map(prevBytesSend -> { - try (var prevBytes = prevBytesSend) { + .map(prevBytes -> { + try (prevBytes) { return deserializeMetadata(prevBytes); } });