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

Fix messages query not releasing

Browse Source
This commit is contained in:
Andrea Cavalli 2021-07-15 15:54:34 +02:00
parent 547fa68fe7
commit e4bbeeca3a
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

@ -1002,7 +1002,7 @@ public class LLLocalDictionary implements LLDictionary {
@Override
public Flux<Entry<ByteBuf, ByteBuf>> putMulti(Flux<Entry<ByteBuf, ByteBuf>> entries, boolean getOldValues) {
return entries
.window(Math.min(MULTI_GET_WINDOW, CAPPED_WRITE_BATCH_CAP))
.bufferTime(Math.min(MULTI_GET_WINDOW, CAPPED_WRITE_BATCH_CAP))
.flatMap(Flux::collectList)
.map(Collections::unmodifiableList)
.flatMap(ew -> Mono