From 586be8751c174322b0975efd75f365205d876acf Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Sat, 31 Jul 2021 19:18:20 +0200
Subject: [PATCH] Fix compilation issue

---
 .../it/cavallium/dbengine/database/disk/LLLocalDictionary.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
index 9a002e7..33c0511 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
@@ -1243,7 +1243,7 @@ public class LLLocalDictionary implements LLDictionary {
 												}
 											})
 											.subscribeOn(dbScheduler)
-											.concatMapIterable(list -> list);
+											.flatMapIterable(list -> list);
 								},
 								entriesWindow -> {
 									for (Tuple2<ByteBuf, X> entry : entriesWindow) {