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

Handle discards

This commit is contained in:
Andrea Cavalli 2022-07-23 15:13:16 +02:00
parent 42fb44f9ed
commit 351a573d6b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/warp/filesponge/FileSponge.java
View File

@ -18,6 +18,7 @@
package org.warp.filesponge; package org.warp.filesponge;
import it.cavallium.dbengine.database.LLUtils;
import it.unimi.dsi.fastutil.objects.ObjectOpenHashSet; import it.unimi.dsi.fastutil.objects.ObjectOpenHashSet;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@ -116,7 +117,7 @@ public class FileSponge implements URLsHandler {
) )
.distinct(DataBlock::getId) .distinct(DataBlock::getId)
.doOnDiscard(DataBlock.class, DataBlock::close); .doOnDiscard(DataBlock.class, LLUtils::onDiscard);
} }
@Override @Override