andreacavalli/FileSponge
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update reactor

Browse Source
This commit is contained in:
Andrea Cavalli 2022-05-21 15:29:48 +02:00
parent 242bd588c6
commit 1e1ccff846
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pom.xml
View File

@ -105,12 +105,12 @@
<dependency> <dependency>
<groupId>io.projectreactor</groupId> <groupId>io.projectreactor</groupId>
<artifactId>reactor-core</artifactId> <artifactId>reactor-core</artifactId>
<version>3.4.13</version> <version>3.4.18</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.projectreactor</groupId> <groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId> <artifactId>reactor-test</artifactId>
<version>3.4.13</version> <version>3.4.18</version>
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<dependency> <dependency>

8
src/main/java/org/warp/filesponge/DiskCache.java
View File

@ -216,8 +216,8 @@ public class DiskCache implements URLsDiskHandler, URLsWriter {
var blockKeyMono = Mono.fromCallable(() -> getBlockKey(url, blockId)); var blockKeyMono = Mono.fromCallable(() -> getBlockKey(url, blockId));
return fileContent return fileContent
.get(null, blockKeyMono) .get(null, blockKeyMono)
.map(dataToReceive -> { .map(data -> {
try (var data = dataToReceive) { try (data) {
int blockOffset = getBlockOffset(blockId); int blockOffset = getBlockOffset(blockId);
int blockLength = data.readableBytes(); int blockLength = data.readableBytes();
if (meta.size() != -1) { if (meta.size() != -1) {
@ -254,8 +254,8 @@ public class DiskCache implements URLsDiskHandler, URLsWriter {
Mono<Buffer> urlKeyMono = Mono.fromCallable(() -> serializeUrl(url)); Mono<Buffer> urlKeyMono = Mono.fromCallable(() -> serializeUrl(url));
return fileMetadata return fileMetadata
.get(null, urlKeyMono) .get(null, urlKeyMono)
.map(prevBytesSend -> { .map(prevBytes -> {
try (var prevBytes = prevBytesSend) { try (prevBytes) {
return deserializeMetadata(prevBytes); return deserializeMetadata(prevBytes);
} }
}); });