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); } }