diff --git a/src/main/java/com/pivovarit/gatherers/DistinctByKeepLastGatherer.java b/src/main/java/com/pivovarit/gatherers/DistinctByKeepLastGatherer.java index 0f7f88b..4d78037 100644 --- a/src/main/java/com/pivovarit/gatherers/DistinctByKeepLastGatherer.java +++ b/src/main/java/com/pivovarit/gatherers/DistinctByKeepLastGatherer.java @@ -21,10 +21,10 @@ public Supplier> initializer() { @Override public Integrator, T, T> integrator() { - return (state, element, _) -> { + return Integrator.ofGreedy((state, element, _) -> { state.put(keyExtractor.apply(element), element); return true; - }; + }); } @Override