Skip to content

Commit a3c39d0

Browse files
committed
ReactiveX#245 Fix Codacy errors
1 parent f6cc95b commit a3c39d0

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

resilience4j-reactor/src/main/java/io/github/resilience4j/reactor/circuitbreaker/operator/CircuitBreakerSubscriber.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ class CircuitBreakerSubscriber<T> extends ResilienceBaseSubscriber<T> {
3737
private StopWatch stopWatch;
3838
private final boolean singleProducer;
3939

40+
@SuppressWarnings("PMD")
4041
private volatile int successSignaled = 0;
4142
private static final AtomicIntegerFieldUpdater<CircuitBreakerSubscriber> SUCCESS_SIGNALED =
4243
AtomicIntegerFieldUpdater.newUpdater(CircuitBreakerSubscriber.class, "successSignaled");
@@ -51,10 +52,8 @@ public CircuitBreakerSubscriber(CircuitBreaker circuitBreaker,
5152

5253
@Override
5354
protected void hookOnNext(T value) {
54-
if (singleProducer) {
55-
if (SUCCESS_SIGNALED.compareAndSet(this, 0, 1)) {
56-
markSuccess();
57-
}
55+
if (singleProducer && SUCCESS_SIGNALED.compareAndSet(this, 0, 1)) {
56+
markSuccess();
5857
}
5958

6059
if (notCancelled() && wasCallPermitted()) {

0 commit comments

Comments
 (0)