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

Add a discard hook

Browse Source
This commit is contained in:
Andrea Cavalli 2021-11-09 15:57:16 +01:00
parent d4dae4667d
commit 42c4b6e651
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
View File

@ -419,7 +419,15 @@ public class LLLocalDictionary implements LLDictionary {
existsAlmostCertainly, UpdateAtomicResultMode.DELTA); existsAlmostCertainly, UpdateAtomicResultMode.DELTA);
return ((UpdateAtomicResultDelta) result).delta(); return ((UpdateAtomicResultDelta) result).delta();
}).onErrorMap(cause -> new IOException("Failed to read or write", cause)), }).onErrorMap(cause -> new IOException("Failed to read or write", cause)),
keySend -> Mono.fromRunnable(keySend::close)); keySend -> Mono.fromRunnable(keySend::close)).doOnDiscard(UpdateAtomicResult.class, uar -> {
if (uar instanceof UpdateAtomicResultDelta delta) {
delta.delta().close();
} else if (uar instanceof UpdateAtomicResultCurrent cur) {
cur.current().close();
} else if (uar instanceof UpdateAtomicResultPrevious cur) {
cur.previous().close();
}
});
} }
@Override @Override