This commit is contained in:
Andrea Cavalli 2021-09-04 16:45:21 +02:00
parent 00a5323913
commit 4e20856317
1 changed files with 3 additions and 3 deletions

View File

@ -214,9 +214,9 @@ public class DiskCache implements URLsDiskHandler, URLsWriter {
key -> fileMetadata.get(null, urlKeyMono), key -> fileMetadata.get(null, urlKeyMono),
Send::close Send::close
) )
.map(diskMetadataSerializer::deserialize) .map(serialized -> {
.map(DeserializationResult::deserializedData) var diskMetadataDeserializationResult = diskMetadataSerializer.deserialize(serialized);
.map(diskMeta -> { var diskMeta = diskMetadataDeserializationResult.deserializedData();
var meta = diskMeta.asMetadata(); var meta = diskMeta.asMetadata();
if (diskMeta.isDownloadedFully()) { if (diskMeta.isDownloadedFully()) {
return Tuples.of(meta, this.requestContent(url)); return Tuples.of(meta, this.requestContent(url));