From a0eee7bdbbe2dd0730d56639f3225d071d40f189 Mon Sep 17 00:00:00 2001 From: Oleh Dokuka Date: Fri, 23 Feb 2024 12:38:00 +0200 Subject: [PATCH] fix gjf Signed-off-by: Oleh Dokuka --- .../io/rsocket/internal/UnboundedProcessorStressTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/rsocket-core/src/jcstress/java/io/rsocket/internal/UnboundedProcessorStressTest.java b/rsocket-core/src/jcstress/java/io/rsocket/internal/UnboundedProcessorStressTest.java index c55d8d8cf..a2d9fcf4d 100644 --- a/rsocket-core/src/jcstress/java/io/rsocket/internal/UnboundedProcessorStressTest.java +++ b/rsocket-core/src/jcstress/java/io/rsocket/internal/UnboundedProcessorStressTest.java @@ -4,7 +4,6 @@ import io.netty.buffer.UnpooledByteBufAllocator; import io.rsocket.core.StressSubscriber; import io.rsocket.utils.FastLogger; - import java.util.Arrays; import java.util.ConcurrentModificationException; import org.openjdk.jcstress.annotations.Actor; @@ -1726,8 +1725,8 @@ public void arbiter(L_Result r) { static void checkOutcomes(Object instance, String result, Logger logger) { if (Arrays.stream(instance.getClass().getDeclaredAnnotationsByType(Outcome.class)) - .flatMap(o -> Arrays.stream(o.id())) - .noneMatch(s -> s.equalsIgnoreCase(result))) { + .flatMap(o -> Arrays.stream(o.id())) + .noneMatch(s -> s.equalsIgnoreCase(result))) { throw new RuntimeException(result + " " + logger); } }