SpringCloud/spring-cloud-commons
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Formatting

Browse Source
This commit is contained in:
spencergibb
2021-01-26 12:01:13 -05:00
parent 00d6a364b2
commit eaa2ddaa86
2 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-commons/src/main/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmitting.java
View File

@@ -16,7 +16,6 @@
package org.springframework.cloud.commons.publisher; package org.springframework.cloud.commons.publisher;
import java.lang.reflect.Field;
import java.util.Iterator; import java.util.Iterator;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
@@ -30,12 +29,11 @@ import reactor.core.publisher.Flux;
import reactor.core.publisher.Operators; import reactor.core.publisher.Operators;
import reactor.util.annotation.Nullable; import reactor.util.annotation.Nullable;
import org.springframework.util.ReflectionUtils;
/** /**
* @author Tim Ysewyn * @author Tim Ysewyn
*/ */
final class FluxFirstNonEmptyEmitting<T> extends Flux<T> implements Scannable, Publisher<T> { final class FluxFirstNonEmptyEmitting<T> extends Flux<T>
implements Scannable, Publisher<T> {
final Publisher<? extends T>[] array; final Publisher<? extends T>[] array;
@@ -274,7 +272,8 @@ final class FluxFirstNonEmptyEmitting<T> extends Flux<T> implements Scannable, P
} }
static final class FirstNonEmptyEmittingSubscriber<T> extends Operators.DeferredSubscription static final class FirstNonEmptyEmittingSubscriber<T>
extends Operators.DeferredSubscription
implements CoreSubscriber<T>, Scannable, Subscription { implements CoreSubscriber<T>, Scannable, Subscription {
final RaceCoordinator<T> parent; final RaceCoordinator<T> parent;

6
spring-cloud-commons/src/test/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmittingTests.java
View File

@@ -160,7 +160,8 @@ public class FluxFirstNonEmptyEmittingTests {
@Test @Test
public void scanSubscriber() { public void scanSubscriber() {
CoreSubscriber<String> actual = new TestSubscriber<>(); CoreSubscriber<String> actual = new TestSubscriber<>();
FluxFirstNonEmptyEmitting.RaceCoordinator<String> parent = new FluxFirstNonEmptyEmitting.RaceCoordinator<>(1); FluxFirstNonEmptyEmitting.RaceCoordinator<String> parent = new FluxFirstNonEmptyEmitting.RaceCoordinator<>(
1);
FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<String> test = new FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<>( FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<String> test = new FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<>(
actual, parent, 1); actual, parent, 1);
Subscription sub = Operators.emptySubscription(); Subscription sub = Operators.emptySubscription();
@@ -176,7 +177,8 @@ public class FluxFirstNonEmptyEmittingTests {
@Test @Test
public void scanRaceCoordinator() { public void scanRaceCoordinator() {
CoreSubscriber<String> actual = new TestSubscriber<>(); CoreSubscriber<String> actual = new TestSubscriber<>();
FluxFirstNonEmptyEmitting.RaceCoordinator<String> parent = new FluxFirstNonEmptyEmitting.RaceCoordinator<>(1); FluxFirstNonEmptyEmitting.RaceCoordinator<String> parent = new FluxFirstNonEmptyEmitting.RaceCoordinator<>(
1);
FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<String> test = new FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<>( FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<String> test = new FluxFirstNonEmptyEmitting.FirstNonEmptyEmittingSubscriber<>(
actual, parent, 1); actual, parent, 1);
Subscription sub = Operators.emptySubscription(); Subscription sub = Operators.emptySubscription();