diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java index 0eaf4d8..eefe956 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java @@ -571,9 +571,9 @@ public class DatabaseMapDictionary extends DatabaseMapDictionaryDeep Stream>> getAllEntriesFastUnsafe(DatabaseMapDictionary dict, BiConsumer, Throwable> deserializationErrorHandler) { try { - return ((LLLocalDictionary) dict.dictionary) - .getAllLiveFiles() - .sequential() + var liveFiles = StreamUtils.toListOn(dict.getDbReadPool(), + ((LLLocalDictionary) dict.dictionary).getAllLiveFiles()); + return liveFiles.stream() .map(file -> file.iterate(new SSTRangeFull()).map(state -> switch (state) { case RocksDBFileIterationStateBegin rocksDBFileIterationStateBegin: yield null;