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:02:45 -05:00
parent ea6598cd3d
commit 4be51d36b8
2 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -32,8 +32,7 @@ import reactor.util.annotation.Nullable;
/**
* @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;
@@ -264,8 +263,7 @@ final class FluxFirstNonEmptyEmitting<T> extends Flux<T>
}
static final class FirstNonEmptyEmittingSubscriber<T>
extends Operators.DeferredSubscription
static final class FirstNonEmptyEmittingSubscriber<T> extends Operators.DeferredSubscription
implements CoreSubscriber<T>, Scannable, Subscription {
final RaceCoordinator<T> parent;

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

@@ -144,8 +144,7 @@ public class FluxFirstNonEmptyEmittingTests {
@Test
public void scanSubscriber() {
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<>(
actual, parent, 1);
Subscription sub = Operators.emptySubscription();
@@ -161,8 +160,7 @@ public class FluxFirstNonEmptyEmittingTests {
@Test
public void scanRaceCoordinator() {
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<>(
actual, parent, 1);
Subscription sub = Operators.emptySubscription();