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

Bugfix

Browse Source
This commit is contained in:
Andrea Cavalli 2021-03-11 15:47:19 +01:00
parent e72b2ca93c
commit 79ba4d8dd2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageMap.java
View File

@ -65,8 +65,8 @@ public interface DatabaseStageMap<T, U, US extends DatabaseStage<U>> extends Dat
default Flux<Entry<T, U>> getAllValues(@Nullable CompositeSnapshot snapshot) { default Flux<Entry<T, U>> getAllValues(@Nullable CompositeSnapshot snapshot) {
return this return this
.getAllStages(null) .getAllStages(snapshot)
.flatMap(entry -> entry.getValue().get(null).map(value -> Map.entry(entry.getKey(), value))); .flatMap(entry -> entry.getValue().get(snapshot).map(value -> Map.entry(entry.getKey(), value)));
} }
default Mono<Void> setAllValues(Flux<Entry<T, U>> entries) { default Mono<Void> setAllValues(Flux<Entry<T, U>> entries) {