This commit is contained in:
Andrea Cavalli 2021-12-17 03:04:01 +01:00
parent 1a35930909
commit 6d92ba8a68
2 changed files with 2 additions and 1 deletions

View File

@ -18,7 +18,7 @@ import static org.lmdbjava.EnvFlags.*;
public class LLTempLMDBEnv implements Closeable { public class LLTempLMDBEnv implements Closeable {
private static final long TWENTY_GIBIBYTES = 20L * 1024L * 1024L * 1024L; private static final long TWENTY_GIBIBYTES = 20L * 1024L * 1024L * 1024L;
private static final int MAX_DATABASES = 1024; private static final int MAX_DATABASES = 16777216;
private final Path tempDirectory; private final Path tempDirectory;
private final Env<ByteBuf> env; private final Env<ByteBuf> env;

View File

@ -184,6 +184,7 @@ public class ScoredPagedMultiSearcher implements MultiSearcher {
return null; return null;
} }
}) })
.subscribeOn(Schedulers.boundedElastic())
.flatMap(cmm -> Flux .flatMap(cmm -> Flux
.fromIterable(indexSearchers) .fromIterable(indexSearchers)
.index() .index()