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

Update BoundedRocksFluxIterable.java

Browse Source
This commit is contained in:
Andrea Cavalli 2021-02-26 15:25:01 +01:00
parent 64b9010e50
commit 4e2030dab8
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/it/cavallium/dbengine/database/BoundedRocksFluxIterable.java
View File

@ -55,8 +55,9 @@ public abstract class BoundedRocksFluxIterable<T> extends BlockingFluxIterable<T
if (range.hasMax() && Arrays.compareUnsigned(key, range.getMax()) > 0) { if (range.hasMax() && Arrays.compareUnsigned(key, range.getMax()) > 0) {
return null; return null;
} }
var transformedEntry = this.transformEntry(key);
rocksIterator.next(); rocksIterator.next();
return this.transformEntry(key); return transformedEntry;
} }
protected abstract ReadOptions getReadOptions(); protected abstract ReadOptions getReadOptions();