diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageMap.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageMap.java index 5bdcff1..fc2b79e 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageMap.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageMap.java @@ -65,8 +65,8 @@ public interface DatabaseStageMap> extends Dat default Flux> getAllValues(@Nullable CompositeSnapshot snapshot) { return this - .getAllStages(null) - .flatMap(entry -> entry.getValue().get(null).map(value -> Map.entry(entry.getKey(), value))); + .getAllStages(snapshot) + .flatMap(entry -> entry.getValue().get(snapshot).map(value -> Map.entry(entry.getKey(), value))); } default Mono setAllValues(Flux> entries) {