diff --git a/dz3r-common/src/main/java/net/sf/dz3r/counter/AbsoluteIncrementAdapter.java b/dz3r-common/src/main/java/net/sf/dz3r/counter/AbsoluteIncrementAdapter.java index 32bf5ab01..786964acb 100644 --- a/dz3r-common/src/main/java/net/sf/dz3r/counter/AbsoluteIncrementAdapter.java +++ b/dz3r-common/src/main/java/net/sf/dz3r/counter/AbsoluteIncrementAdapter.java @@ -31,7 +31,7 @@ public final Flux split(Flux snapshots) { return snapshots.flatMap(this::convert); } - private synchronized Flux convert(T snapshot) { + private Flux convert(T snapshot) { if (lastKnown == null) {