diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmitting.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmitting.java
index c798c7f3..67ef32e9 100644
--- a/spring-cloud-commons/src/main/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmitting.java
+++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmitting.java
@@ -16,7 +16,6 @@
 
 package org.springframework.cloud.commons.publisher;
 
-import java.lang.reflect.Field;
 import java.util.Iterator;
 import java.util.Objects;
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
@@ -30,12 +29,11 @@ import reactor.core.publisher.Flux;
 import reactor.core.publisher.Operators;
 import reactor.util.annotation.Nullable;
 
-import org.springframework.util.ReflectionUtils;
-
 /**
  * @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;
 
@@ -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 {
 
 		final RaceCoordinator<T> parent;
diff --git a/spring-cloud-commons/src/test/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmittingTests.java b/spring-cloud-commons/src/test/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmittingTests.java
index 4ac24655..bcf117a3 100644
--- a/spring-cloud-commons/src/test/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmittingTests.java
+++ b/spring-cloud-commons/src/test/java/org/springframework/cloud/commons/publisher/FluxFirstNonEmptyEmittingTests.java
@@ -160,7 +160,8 @@ 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();
@@ -176,7 +177,8 @@ 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();