From 351a573d6b45f05c3a4d9c2df818c9991f770f8e Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Sat, 23 Jul 2022 15:13:16 +0200 Subject: [PATCH] Handle discards --- src/main/java/org/warp/filesponge/FileSponge.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/warp/filesponge/FileSponge.java b/src/main/java/org/warp/filesponge/FileSponge.java index 2840233..86bc12b 100644 --- a/src/main/java/org/warp/filesponge/FileSponge.java +++ b/src/main/java/org/warp/filesponge/FileSponge.java @@ -18,6 +18,7 @@ package org.warp.filesponge; +import it.cavallium.dbengine.database.LLUtils; import it.unimi.dsi.fastutil.objects.ObjectOpenHashSet; import java.util.ArrayList; import java.util.List; @@ -116,7 +117,7 @@ public class FileSponge implements URLsHandler { ) .distinct(DataBlock::getId) - .doOnDiscard(DataBlock.class, DataBlock::close); + .doOnDiscard(DataBlock.class, LLUtils::onDiscard); } @Override