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

Fix compilation issue

Browse Source
This commit is contained in:
Andrea Cavalli 2021-07-31 19:18:20 +02:00
parent d411675c2b
commit 586be8751c
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1243,7 +1243,7 @@ public class LLLocalDictionary implements LLDictionary {
}
})
.subscribeOn(dbScheduler)
.concatMapIterable(list -> list);
.flatMapIterable(list -> list);
},
entriesWindow -> {
for (Tuple2<ByteBuf, X> entry : entriesWindow) {